Python3.x 如何使用 Celery 和 Django 将任务路由到不同的队列

我正在使用以下堆栈:

• Python 3.6
• Celery v4.2.1(经纪人:RabbitMQ v3.6.0)
• Django v2.0.4

根据Celery's documentation，在不同的队列上运行计划任务应该和为CELERY_ROUTES上的任务定义相应的队列一样简单，尽管如此，所有任务似乎都是在Celery 的默认队列上执行的.

这是my_app/settings.py上的配置:

CELERY_BROKER_URL = "amqp://guest:guest@localhost:5672//"
CELERY_ROUTES = {
 'app1.tasks.*': {'queue': 'queue1'},
 'app2.tasks.*': {'queue': 'queue2'},
}
CELERY_BEAT_SCHEDULE = {
    'app1_test': {
        'task': 'app1.tasks.app1_test',
        'schedule': 15,
    },
    'app2_test': {
        'task': 'app2.tasks.app2_test',
        'schedule': 15,
    },

}

这些任务只是测试路由的简单脚本:

文件app1/tasks.py:

from my_app.celery import app
import time


@app.task()
def app1_test():
    print('I am app1_test task!')
    time.sleep(10)

文件app2/tasks.py:

from my_app.celery import app
import time


@app.task()
def app2_test():
    print('I am app2_test task!')
    time.sleep(10)

当我用所有需要的队列运行Celery 时:

celery -A my_app worker -B -l info -Q celery,queue1,queue2

RabbitMQ将显示只有默认队列"celery"正在运行任务:

sudo rabbitmqctl list_queues
# Tasks executed by each queue:
#  - celery 2
#  - queue1 0
#  - queue2 0

有人知道如何修复这种意外行为吗？

当做