問題タブ [pika]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - tornadoアプリでRabbitMQ(Pikaライブラリ)と通信する方法
Pika ライブラリはトルネード アダプターをサポートしています。非同期アダプターを使用してメッセージを発行する方法の例を次に示します。
トルネードアプリでピカピカを使いたいのですが、例として、トルネードのリクエストデータをRabbitMQに入れたいのですが、やり方がわかりません。
解き方がわからない2問。
1ピカ使用のトルネードアダプターには独自のioloopがあり、
Tornado アプリケーションには独自の ioloop があり、
これら 2 つの ioloop を組み合わせる方法は?
2 Pika の例では同じメッセージが何度も発行されますが、リクエスト データを発行したいのですが、リクエスト データを発行メソッドに渡すにはどうすればよいですか?
python - メッセージにフィールドを追加するか、カスタム ヘッダーを作成するか、どちらがより効率的ですか? RabbitMQ
キューに発行するときに、各メッセージにメタ データを追加する必要があります。問題は、どの方法がより効率的かということです。
- すべてのメッセージ本文にカスタム フィールドを追加する
- すべてのメッセージにカスタム ヘッダーを追加する
念のため：
- パブリッシャーは AWS m1.small 上にあります
- メッセージ レートが 500 メッセージ/秒未満
- うさぎライブラリ: pika (python)
python - Set max number of messages in the queue
I'm wondering is it possible to set the max number of messages in the queue?
Let's say I want to have no more than 100 msgs in queue Foo, is it possible to do?
rabbitmq - 単一の接続 (pika/rabbitmq) から新しいチャネルを作成する方法は?
私は pika 0.9.13 を使用して RabbitMQ に接続する python コードを書いています。多くの子プロセス (潜在的に数千) を作成しており、各プロセスが RabbitMQ に送信できるようにしたいと考えています。読んでみると、単一の接続を作成し、その接続内にチャネルを作成するのが最善の方法のようです。
これをどのように行うのが最善か誰にもアドバイスできますか？通常、コードは次のようになります:-
どのタイプのアダプターを使用すればよいですか (BlockingConnection ?) ...
前もって感謝します ！
python - コード設計: try except ブロックから Rabbit にメッセージを再送信する
私は助けを探しています。メッセージが実際にサーバーに配信されなかった場合にinsert_order_queue()メッセージを再送信できるように機能を修正したいと考えています。RabbitMQ
これは私の現在のコードです：
そして、これが私の_connect()方法です：
python - RabbitMQ でメッセージが拒否/再キューイングされた回数を確認するにはどうすればよいですか?
私は pika (Python) で RabbitMQ を使用していますが、メッセージが再キューイングされた回数を判断する方法があるかどうか疑問に思っています。
一般的な考え方は、処理しているメッセージが X 回前に拒否/再キューイングされたことをワーカーに伝え、適切なアクションを実行してエラー処理を実行し、アイテムを明示的に削除できるようにすることです。 Y 回の再試行の制限に達した場合、キュー。
メッセージのコピーを作成し、priority プロパティの値をインクリメントする (またはヘッダーの値をインクリメントする) 可能性があることを知っています。次に、コピーをキューに発行し、元のメッセージを確認します (アプローチと同様)。この例を見つけました)、しかし私は明示的にメッセージを nack して再キューイングすることを好みます。
何か案は？