4

我正在使用 django 和 djcelery。由于有些任务有点重,我希望它们在一个单独的队列中。

根据用户指南中关于自动路由的部分,您可以通过设置变量来实现CELERY_ROUTES。但是这不起作用,所有任务最终都在默认队列中。当我在我的任务类中明确设置队列变量时,它确实有效。

在我的设置文件中,我有

CELERY_ROUTES = {"analysis.tasks.analyze_item": {"queue": "analysis_queue"}}

我开始芹菜工人

python manage.py celeryd -Q analysis_queue

我的任务.py

class Analyze(Task):
    queue = 'analysis_queue' # <--- without this it doesn't work..
....


analyze_item = registry.tasks[Analyze.name]
4

0 回答 0