目前,我们的Django应用程序中有几个芹菜队列。现在,我们要么在CELERY_ROUTES设置中为每个任务指定一个队列(如果没有定义,它将转到默认队列),要么在任务定义中指定。
我在我们的整个项目中推出了一个新的django应用程序,我想为该应用程序中的所有任务指定一个队列,而不是基于每个任务。有没有一种简单的方法可以做到这一点?
谢谢!
发布于 2018-10-10 03:23:47
真的很老的问题,但现在它开始了.在documentation http://docs.celeryproject.org/en/latest/userguide/routing.html#id2中,您可以指定tasks.py中与您的应用程序相关的所有任务,以使用特定查询:
task_routes = ([
('feed.tasks.*', {'queue': 'feeds'}),
('web.tasks.*', {'queue': 'web'}),
(re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}),
],)
在您的芹菜配置文件中。
https://stackoverflow.com/questions/28117938
复制相似问题