問題タブ [python-pika]

pika のツイスト プロトコル アダプターを使用しています。メッセージを正常に処理したら、次の呼び出しを使用して、RabbitMQ に確認を送信します。

basic_ack 呼び出しは非同期で起動しているようですが、遅延を返さないため、コールバックまたはエラーバックを追加できません。キューからの特定のメッセージを待ち、それを処理してリアクターをシャットダウンしたいので、小さな問題に遭遇しました。

もちろん、リアクターはメッセージが送信される前にシャットダウンします。シャットダウンを遅らせることでこれを回避しています

しかし、それはかなり「ハッキー」な方法のようです。私は次のようなことができるようにしたいと思います:

ここで明らかな何かが欠けていますか？ack 呼び出しの最後にコールバックをチェーンすることは本当に不可能ですか?

RabbitMQ サーバーへの接続に使用され、メッセージを消費する Python のスクリプトがあります。コマンドプロンプトからスクリプトを実行しようとすると"./pikascript.py"、適切な出力が得られますが、同じスクリプトを「python pikascript.py」として実行しようとすると、次のエラーが発生します。

環境変数に適切なパスを指定しました。ピカライブラリを実行するための依存関係はありますか..誰かが私を助けてくれませんか.

10,000 行のテーブルがあり、最初の 1000 行を選択してからもう一度選択し、今度は次の行セット (1001 ～ 2001) を選択したいと考えています。

BETWEEN値の範囲を選択するために句を使用しています。値をインクリメントすることもできます。これが私のコードです：

私が達成したいのは、メッセージング キュー、RabbitMQ を使用することです。この行を別のデータベースに送信し、プロセスをスピードアップしたいと考えています。すべてを選択してキューに送信すると、エラーが返されます。

コードの出力は、1 回目で 1 ～ 1000 行を正しく返しますが、2 回目のループでは、1001 ～ 2001 行ではなく、1 ～ 2001 行、1 ～ 3001 行などを返します。 1.

シンプルな Python Pika SelectConnection を作成しようとしていますが、on_open_callback を使用して接続を開くことができず、on_open_error_callback からも何も得られないようです。誰かが問題の原因を示唆できますか?

rabbitmq ブローカーを使用するクライアント サーバー アプリケーションがあります。クライアントは rabbitmq に接続し、サーバーにメッセージを送信します。ある時点で、サーバーがこのクライアントをrabbitmqに接続すべきではないと判断した場合、クライアントをrabbitmqボーダーから強制的に切断できるようにしたいと考えています。私の場合、切断するためにクライアントにメッセージを送信したくないことに注意してください。サーバー側では、このクライアントをrabbitmqから強制的に切断したいだけです。

これを行うための API が見つかりませんでした。どんな助けでも感謝します。

私はピカに不慣れです（https://github.com/pika/pika）。仮想ホストが1つ存在するかどうかを確認するAPIや、仮想ホストを作成するAPIなどはあるのでしょうか。vhost は rabbitmqctl で作成できることは知っていますが、pika でそれらを見つけられませんでした... 何か見逃しましたか?

When I am trying to import pika in my python module and it shows error message as Unresolved import: pika

I am using windows os