Pika: write buffer exceeded

Question

Our software program worked fine for 5 months, and now we started to receive Pika warnings, which ultimately lead to an exception.

Pika 0.9.5 UserWarning: write buffer exceeded warning threshold.

I searched a lot of forums, but very little satisfaction. One of the solutions described was to completely ignore these warnings, but I am a little skeptical about this. Any help in this matter would be greatly appreciated. This is very relevant.

thanks

Answer 1

This: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-April/012223.html explains the problem well. The problem is that you write much faster than you consume from the queue . And the warning just tells you that.

You can configure:

connection.set_backpressure_multiplier(NNNN) 

but this will not solve the problem, it will simply hide the warnings for some time.

Depending on the application, you may need to attach the code to add_backpressure_callback : http://pika.github.com/connecting.html#adapters.select_connection.SelectConnection.add_backpressure_callback

and do some cleaning or something else that is required when the backpressure is hit. But first of all, check your code and find the reason for the overload.