python-pika

1熱

1答えて

Python 3.6：クラスを使用せずにSelectConnectionアダプタを使用してpikaコンシューマを作成するにはどうすればよいですか？

私はpythonとpikaには新しく、数時間後に例外をスローし続けるBlockingConnectionアダプタを使用してキューから消費する問題にぶち当たっています。 私は今、SelectConnection（非同期）アダプタを使用しようとしていますが、このアダプタタイプをクラス内で使用し、クラスベースのコードで作業するサンプルは、私の理解をはるかに超えています。 SelectConnection

python-3.x amqp python-pika 2017-08-23

---

0熱

1答えて

ドッカーodoo 9インストールpikaエラー

私は達成したい単純なドッカービルドを持っています。 odoo FROMナキウサギライブラリ を9にしてインストールします：ベースイメージodooを引い9 RUNはナキウサギ をインストールPIPが、私はこのエラーを取得していますように進行することはできません。 enter image description here btw、私はWindows環境でドッカーを使用しています。

docker odoo-9 python-pika 2017-04-07

---

0熱

1答えて

複数の待ち行列のためのrabbitmqの複数のコンシューマ

私は2つのキュー、例えばq1とq2を持っています。これはバインディングキーb1とb2でe1とe2の交換に相当します。 q1とq2をそれぞれ聞くc1とc2と言って、コンシューマ関数を並列に実行したい。 def c1(): connection = pika.BlockingConnection(pika.ConnectionParameters(host=constants.rmqHost

python rabbitmq pika python-pika 2017-07-16

---

0熱

2答えて

ackを使わずにrabbit msgを取得しようとしましたが、成功しませんでした。

私はウサギのキューにあるすべてのメッセージを取得しようとしています。私は取得する必要があり、消費しないでください。 だからここにコードがある、私はこのコードを実行すると、それが正常に動作しますが、最初のtime.Iは、キュー内のすべてのメッセージを取得し、すべてのメッセージが「準備完了」状態のままに、しかしとき def some_function_name() : connection

python rabbitmq pika python-pika 2017-09-12

---

0熱

2答えて

PythonはRabbitMQの

以下 に関数の外の変数の値を取得producer.py def callback(ch, method, properties, body): result = body.decode() resp = JSONEncoder().encode(result) json_resp = json.loads(resp) print(json_resp) ch.basic_ack(deliv

python-3.x rabbitmq python-pika 2017-09-13

---

1熱

1答えて

Python - 別のスレッドで実行される関数間で関数（コールバック）変数を渡す

pikaとスレッドモジュールを使用するPython 3.6スクリプトを開発しようとしています。 私はA）はPythonとPythonにはまったく新しく、B）別々のスレッドで実行され、すでに渡されているときに関数間で変数を渡す方法を理解していないという問題があります。受信関数名の最後のカッコ内のパラメータ。 私はこれを考えている理由は、スレッディングを使用しないと、受信関数名を呼び出すだけで関数間で

python-3.x rabbitmq amqp python-multithreading python-pika 2017-07-31

---

0熱

1答えて

pika（pythonクライアント）を使用してRabbitMQでMQTTメッセージをパブリッシュ/サブスクライブする

私は既存のRabittMQサーバーをセットアップしており、MQTTプラグインがmqttメッセージをパブリッシュ/サブスクライブできるようにしました。 既存のキューメッセージを処理するpikaクライアントがあります。今、私は同じpika on_message（）ハンドラを使ってmqttメッセージを処理したいと考えています。 eclipse pahoクライアント上でmqttメッセージを発行して購読する

rabbitmq paho pika python-pika 2017-11-08

---

0熱

1答えて

PikaはubuntuでRabbitMqに接続できますが、Centosでは動作しませんか？

同じコードはUbuntuで動作し、Centosでは動作しません！ファイアウォールはすでに閉じている Ubuntu 16.04、python version 3.5.2。 Centos 7、pythonバージョン3.5.2。 Ubuntuとcentosは新しくvirtualboxにインストールされました！ RabbitMq config tls！ CentOSの場合、接続するとrabbitmqは無効

python ubuntu centos rabbitmq python-pika 2016-08-22

---

0熱

1答えて

グローバル変数を使用しているにもかかわらず、このグローバル変数がPython 2.7で更新されないのはなぜですか？

私は、各メッセージが受信されると、AMQPメッセージの本文を返すコールバック関数を持っています。本文の内容をグローバル変数に代入し、それから私のプログラムでそれを扱うことができるようにしたいと思います。 スクリプトの先頭にグローバル変数を作成し、コールバック関数内でglobalキーワードを使用していますが、これはスクリプトの上部にあるグローバル変数を更新できるはずですが、テスト「私はの元の値を取得

python-2.7 function callback global-variables python-pika 2016-12-01

---