python - 具有非同质任务的 Celery

Question

我有两个celery worker ， worker 1有任务A和B， worker 2有任务A，B和C。如果我提交任务C，它似乎没有在有任务的celery worker 中执行C;有什么方法可以确保只有工作人员 2 获得分配的任务 C 吗？

Answer 1

我会看一下routing tasks在文档中。您可以创建具有特定主题的队列，并指定哪些工作人员可以处理哪些队列。