我们经常需要使用芹菜（由RabbitMQ支持）将许多消息排队（我们将它们分成1000个组）。有人能做到吗？我们基本上是试图在一个send_task调用中“批处理”大量消息。
如果我猜我们需要更深入一步，然后进入kombu甚至py-amqp。
当做，
尼克拉斯
最佳答案
不需要“深入”直接使用Kombu。-很少有适合不同用例的解决方案：
如果您喜欢使用芹菜工作流，您可能希望利用chunks。
没有什么能阻止您调用send_task（）数千次。
如果调用send_task（）太慢，则可能需要使用一个线程池，该线程池将同时向队列发送N个任务。