Kombu发布时断开连接

Question

我在使用kombu 4.1发布消息时遇到问题。我的用例是，我有一个服务器，它从rabbitmq队列（队列1）收集消息，执行一些处理任务，然后将它们重新发布到另一个队列（队列2）。我从队列1消费没有问题，但是当我尝试发布到队列2时，有一个间歇性故障导致我断开与rabbitmq的连接。我已经激活了retries和ConsumerProducerMixin，但问题仍然存在。我也在kombu github页面上发布了这个问题可用：-https://github.com/celery/kombu/issues/857

有人对这个问题有什么见解吗？它会在kombu 4.2中修复吗？有没有解决办法不涉及切换到另一个库？在

谢谢你

Answer 1

对于为什么会发生这种情况，并不是一个真正的答案，而是两个似乎能为我们解决问题的解决办法。在

• 打开新连接时设置heartbeat=0（但可能需要hearbeats）。在
• 将kombu版本降级到v4.0.2。如前所述，here，task_publish_retry_policy似乎从{}中断

我希望这有帮助！在