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

这并不是为什么会发生这种情况的真正答案，而是两个似乎可以为我们解决问题的变通方法。

当打开一个新的连接时，kombu

• 会设置heartbeat=0 (但你可能需要v4.0.2版本的kombu。正如here所说，task_publish_retry_policy似乎与kombu==4.1.0

分离了

我希望这能帮到你!