pika

9熱

2答えて

PikaまたはRabbitMQでは、消費者が現在消費しているかどうかを確認するにはどうすればよいですか？

消費者/労働者がある場合は、を消費することを確認したいと思います。私はお送りしようとしています。任意のワーカーがない場合、私はいくつかの労働者を開始（消費者や出版社の両方が単一のマシン上にある）、その後メッセージを公開して行くでしょう。 connection.check_if_has_consumersのような機能があれば、私は多少このようにそれを実装するだろう - import pika i

6熱

1答えて

3つのハートビートの後でPika接続が終了しました

HTTPリクエスト（Tornadoを使用）を受信して解析し、pikaを使用してRabbitMQブローカに送信するスクリプトを作成しています。コードは次のようになります。 def main(): conn_params = pika.ConnectionParameters( host=BROKER_NAME, port=BROKER_PORT, s

5熱

1答えて

竜巻アプリケーションでRabbitMQ（Pikaライブラリ）を通信する方法

Pikaライブラリサポート竜巻アダプタ、hereは、非同期アダプタを使用してメッセージを発行する方法の例です。私は竜巻アプリケーションでpikaを使用したいと思います。ただの例ですが、私は竜巻リクエストデータをRabbitMQに入れたいが、どうやってそれを行うのか分からない。 2つの質問は解決する方法がわかりません。 1ピカ使用竜巻アダプタは、独自のioloopを持ち、 self._connec

11熱

1答えて

ピカ+のRabbitMQ：= 1をプリフェッチするbasic_qosを設定するには、まだ私はRabbitMQのキューに各フック10人の労働者をスピンアップのpythonワーカークライアントを持っているキュー

内のすべてのメッセージを消費するように見えます。このようなビット： #!/usr/bin/python worker_count=10 def mqworker(queue, configurer): connection = pika.BlockingConnection(pika.ConnectionParameters(host='mqhost')) channel

0熱

1答えて

タイムアウトをpika.Blocking接続経由で送信することができません

タイムアウトを設定するrabbitmqサーバから受信するクライアントプログラムを作成しようとしています。指定した時間が経過すると、クライアントはキューからメッセージを消費して終了する必要があります。私はブロッキング接続でピカを使用しています。私は、ブロック接続で定義されたadd_timeout（遅延、コールバック）を見ましたが、私がそれを使用しようとしているとき、次のエラーが発生しています。 [

6熱

2答えて

rabbitmq、pika pythonで正常に消費を一時停止して再開する方法

メッセージの受信にはbasic_consume（）を使用していますが、消費をキャンセルするにはbasic_cancelを使用していますが、問題があります。あなたは私が消費consumer_tagが_canceledリストに追加されたキャンセルてるたびに見ることができるようにここではpika.channel def basic_consume(self, consumer_callback, qu

15熱

2答えて

ロガー "pika.adapters.blocking_connection"のハンドラが見つかりません

類似の質問はすべてカスタムロガーの使用に基づいているようですが、デフォルト/なしを使用するのはうれしいです。私のピカピソンのアプリが実行され、メッセージを受信しますが、数秒後にNo handlers could be found for logger "pika.adapters.blocking_connection"、任意のアイデアでクラッシュ？追加することにより、固定 import logg

21熱

1答えて

pikaで使用する接続形式

私はpikaを使用する際にどの形式の接続を使用するのか把握しようとしていますが、私は理解できる限り2つの選択肢があります。 BlockingConnectionまたはSelectConnectionのいずれかが、しかし、私は（すなわちBlockingConnectionブロッキング？ともっとされているもの）は、これらの2つの間の違いについては本当にわからないんだけど pikaのドキュメントはSel

5熱

2答えて

Pikaとgeventでランダムタイムアウトエラーが発生しました

私はgeikaプログラム内でPikaライブラリ（geventでパッチを当てた猿）を使用してRabbitMQを使用しようとしていましたが、ランダムにタイムアウトエラーが発生しました。どうすればよいですか？私が使うことができる別の図書館はありますか？ WARNING:root:Document not found, retrying primary. Traceback (most recent

6熱

1答えて

メッセージを確実に配信する方法を教えてください。

メッセージはPikaで確実に配信されますか？メッセージが正常に配信されなかった場合、デフォルトではエラーは表示されません。この例では、pikaが接続が切断されたことを確認する前に、いくつかのメッセージを送信できます。 import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host='l