python - Pika:写入缓冲区超出警告

Question

我们的软件程序正常运行了 5 个月，现在突然间我们开始收到 Pika 警告，最终导致异常。

Pika 0.9.5 UserWarning:写入缓冲区超出警告阈值。

我搜索了很多论坛，但都不太满意。所描述的一种解决方案是完全忽略这些警告，但我对此持怀疑态度。在此问题上的任何帮助将不胜感激。非常紧急。

谢谢

Answer 1

这个:http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-April/012223.html很好地解释了问题。 问题是你写的比从队列中消费快得多。警告只是告诉您这一点。

你可以调整:

connection.set_backpressure_multiplier(NNNN) 

但这并不能解决问题，只是会隐藏警告一段时间。

根据应用程序 - 您可能需要将一些代码附加到 add_backpressure_callback: http://pika.github.com/connecting.html#adapters.select_connection.SelectConnection.add_backpressure_callback

并在遇到背压时进行一些清理或任何需要的事情。但首先 - 检查您的代码并找出导致过载的原因。