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

，并做一些清理工作或任何反压被击中时，是必要的。但首先 - 检查你的代码，找出造成过载的原因。