我们在heroku上有一个应用程序设置，它使用芹菜来运行后台作业。芹菜应用程序使用 RabbitMQ 作为代理。我们使用heroku的RabbitMQ Bigwig附加组件作为AMQP消息代理。此插件指定两个单独的 URL，一个针对生产者优化，另一个针对消费者优化。此外，根据 RabbitMQ 文档，建议对生产者和消费者使用单独的连接。
Celery 文档不提供单独指定与生产者和使用者的连接的方法。有没有办法在芹菜中指定两个不同的代理 URL？
不幸的是，没有一种干净的方法可以做到这一点。您可以在 task.apply_async 上显式提供自定义代理连接，但这意味着放弃连接池功能。它可能对你有用。
from kombu import BrokerConnection
conn = BrokerConnection(hostname="producerbroker")
mytask.apply_async(args, kwargs, connection=conn)
最直接的解决方案可能是为生产者和工作线程提供不同的配置文件。