celery - 如何将 Supervisor + Django + Celery 与多个队列和工作人员一起使用？

Question

我正在使用 Celery + Django + Supervisord，我正在尝试通过创建 3 个不同的队列来设置“优先级”（如https://stackoverflow.com/a/15827160/54872所建议的那样）。

有没有办法在主管的一个命令中为每个队列启动 celery beat 和工作人员？或者，我是否需要为每个队列/工作池和芹菜节拍制作不同的主管配置文件？

Answer 1

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

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

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

[group:workers]
programs=worker1,worker2