rabbitmq - 使用 Celery 和 RabbitMQ 的简单队列

Question

我正在尝试实现一个一次执行一项任务的简单队列。使用 Celery 将任务从主线程中卸载并在 Celery 配置中设置 concurrency=1 可以正常工作，但我可能希望为其他任务使用更多并发工作人员。

有没有办法告诉 Celery 或 RabbitMQ 不要为一个任务使用多个并发工作人员（除非强制并发 = 1）？我在文档中找不到任何东西，但也许这些工具不是为线性队列设计的？

谢谢！

Answer 1

我认为您需要为每种类型的任务设置一个单独的队列。创建从每个队列消费的单独工作人员，并发设置为 1。