Kombu 在发布时断开连接

Question

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

是否有人对此问题有任何见解，是否会在 kombu 4.2 中修复，是否有任何不涉及切换到另一个库的解决方法？

谢谢

Answer 1

并没有真正回答为什么会发生这种情况，但有两种解决方法似乎可以为我们解决问题。

• 在打开新连接时设置heartbeat=0（但也许您需要心跳）。
• 将kombu 版本降级为v4.0.2。如here 所述，task_publish_retry_policy 似乎与kombu==4.1.0 不同

我希望这会有所帮助！