【发布时间】:2012-06-26 15:26:18
【问题描述】:
我们的软件程序运行良好 5 个月,现在突然我们开始收到 Pika 警告,最终导致异常。
Pika 0.9.5 UserWarning:写入缓冲区超出警告阈值。
我搜索了很多论坛,但都不太满意。描述的一种解决方案是完全忽略这些警告,但我对此有点怀疑。在这件事上的任何帮助将不胜感激。很紧急。
谢谢
【问题讨论】:
我们的软件程序运行良好 5 个月,现在突然我们开始收到 Pika 警告,最终导致异常。
Pika 0.9.5 UserWarning:写入缓冲区超出警告阈值。
我搜索了很多论坛,但都不太满意。描述的一种解决方案是完全忽略这些警告,但我对此有点怀疑。在这件事上的任何帮助将不胜感激。很紧急。
谢谢
【问题讨论】:
这个: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
并在遇到背压时进行一些清理或任何需要的事情。但首先 - 检查您的代码并找出导致过载的原因。
【讨论】: