pika

3熱

2答えて

"エラー：erlangの配布を初期化できませんでした" "rabbitmqctl status"を実行しようとしています

この質問は以前（RabbitMQ Failed to initialize erlang distribution）で聞かれましたが、私は既存の回答から修正する方法を見つけることができませんでした。 https://www.rabbitmq.com/man/rabbitmqctl.1.man.htmlに続いて、rabbitmqctl statusコマンドを実行してRabbitMQブローカに関する情

0熱

1答えて

セロリでlibrabbitmqの代わりにpikaを使用することは可能です

Librabbitmqの代わりにPikaをセロリで使用することはできますか？その場合：それはどんなパフォーマンスの低下を持っていますか？特別な設定が必要ですか？

0熱

1答えて

マルチプロセスウサギ消費者

ありがとうございます。マルチプロセッシングの新機能です。私はRabbit MQueueのデータを同時に消費するプロセスを作成しましたが、一度に1つのプロセスしか実行しません。 def start_consum(queue_name): channel.basic_consume(func, queue=queue_name) channel.start_consuming(

4熱

1答えて

並行して多くのデキューメッセージを消費するためにconcurrent.futuresを使用する

RabbitMQチャネルからメッセージを消費していますので、一度にn個の要素を消費することができます。私はProcessPoolExecutor（またはThreadPoolExecutor）を使うことができると思います。無料のエグゼキュータがプールにあるかどうかを知ることができるかどうかは疑問です。これは私が書きたいものです。 executor = futures.ProcessPoolExe

0熱

1答えて

RabbitMQ pika非同期消費者のハートビートの問題

RabbitMQとpika（python）を使用して、ノード（非同期コンシューマ）にタスクを提供するジョブキューイングシステムを実行しています。タスクを定義する各メッセージは、そのタスクが完了するとただちに承認されます。これらのノードで更新を実行する必要があり、ノードがタスクの完了を待ってから正常に終了する終了モードを作成しました。私は私のメンテナンス作業を行うことができます。この終了モードで

0熱

1答えて

キューを検出する方法が削除されましたか？

PikaClientが消費するキューを手動で削除すると、何も起こりません。私は同じ名前のキューを再作成することができますが、チャネルはキューを消費するために停止しています（削除したので正常です）。しかし、消費されたキューが削除されたときにイベントを受信したいと考えています。チャンネルは自動的に閉じられるが、«on_channel_close_callback»は決して呼び出されないと予想した。

0熱

1答えて

EC2でRabbitMQサーバーにメッセージを送信中に接続エラーが発生しました

AWS EC2でRabbitMQ Serverが実行されていますプロデューサとコンシューマコードをローカルで実行しました。それは働いている。私はrabbitMQ管理Webアプリケーションにもアクセスできます。私はEC2 に私のラップトップからデータをプッシュしようとしていたとき、私はこの行に、このエラーを取得しています： connection = pika.BlockingConnectio

0熱

1答えて

なぜAMQPは双方向RPCプロトコルですか？

私はPikaのドキュメントを読んでいますが、「AMQPはクライアントがサーバーに要求を送信し、サーバーがクライアントに要求を送信できる双方向RPCプロトコルです」という理由をよく理解していません。誰か私に例を教えてもらえますか？私たちは交換を作成することを意味しますか？クライアントが送信します。exchange.declare サーバが返信：exchange.declare-OK は、これら2

0熱

2答えて

、）（basic_ackんが

は、私は次のようにRabbitMQのへの接続を行っていると言うのコールバック関数に配置する必要があります。 connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost', 5672, '/', credentials)) channel = connection.channel() channel

0熱

1答えて

rabbitmq_delayed_message_exchangeを使用している間に遅延メッセージがキューに表示されない

このプラグインを使用しようとしていて、とてもシンプルで効果的でした。私は交換を作成することができましたが、リクエストを公開しているときに、xディレイ値がゼロでない場合、キューにメッセージが渡されているのを見ることができません。（xディレイは0になります）私はpikaとpythonを使用しています。次のコマンドは、交換を作成するために使用されました： channel.exchange_declar