python - Pika: 書き込みバッファ超過警告

Question

私たちのソフトウェア プログラムは 5 か月間問題なく動作していましたが、突然 Pika 警告が表示されるようになり、最終的に例外が発生しました。

Pika 0.9.5 UserWarning: 書き込みバッファが警告しきい値を超えました。

私は多くのフォーラムを検索しましたが、ほとんど満足できませんでした。説明されている 1 つの解決策は、これらの警告を完全に無視することでしたが、私はそれについて少し懐疑的です。この問題についての助けをいただければ幸いです。非常に緊急です。

ありがとう

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

背圧がかかっているときにクリーンアップや必要なものを実行します。しかし、まず第一に、コードをチェックして、オーバーロードの原因を見つけてください。