如何使用Supervisor + Django + Celery与多个队列和工人？

Question

我正在使用Celery + Django + Supervisord,我正在尝试通过创建3个不同的队列来设置"优先级"(如/sf/answers/1107901231/所示).

有没有办法在主管的一个命令中为每个队列启动芹菜殴打和工人？或者,我是否需要为每个队列/工作人员池制作不同的管理员配置文件,并为芹菜打败一个？

Answer 1

您可以为每个队列创建程序部分,并将它们组合在一个组部分中:

[program:worker1]
command=celery worker --queues=queue1

[program:worker2]
command=celery worker --queues=queue2

[group:workers]
programs=worker1,worker2