pika

0熱度

1回答

我用這樣的顯示here方法cosume單個消息： while method_frame is None: method_frame, header_frame, method_frame= channel.basic.get("test_queue) 它看起來是這樣的投票不那麼高效這種方式，因爲基本的get如果隊列是空的，並且帶空信息，它也在工作。我需要一種邏輯，它只需要一個消息，只有當我有機會

2熱度

1回答

在RabbitMQ上使用python和pika從遠程虛擬機執行handshake_timeout

我在世界各地都有幾個虛擬機，全部完全相同，並且使用相同的python代碼（和pika 0.9.13相同的庫版本）。其中只有一個是因爲handshake_timeout的失敗： =ERROR REPORT==== 17-Jun-2015::12:27:07 === closing AMQP connection <0.290.0> (YY.YY.YY.YY:47232 -> XX.XX.XX.XX

2熱度

1回答

Pika channel.stop_consuming不停止start_consuming循環

我有這段代碼，基本上它運行的是 channel.start_consuming（）。我希望它在一段時間後停止。我認爲 channel.stop_consuming（）是正確的方法： def stop_consuming(self, consumer_tag=None): """ Cancels all consumers, signalling the `start_consumin

0熱度

1回答

RabbitMQ的連接錯誤

我對MQ和pika是全新的。當我試圖執行此代碼（服務器代碼）我得到錯誤：（我收到同樣的錯誤接收器代碼也） import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host="localhost:5672")) channel = connection.channel() channel.

0熱度

1回答

在異步模式下使用pika，我如何獲得服務器命名隊列的名稱？

我正在關注的asynchronous consumer example，我想如下聲明服務器命名隊列： channel.queue_declare(on_queue_declareok, '') 我的回調看起來是這樣的： def on_queue_declareok(frame): queue_name = ???? # What goes here? channel.que

1熱度

1回答

的RabbitMQ發送ACK

我的RabbitMQ消費者過程如下面的示例所示進來的消息時斷開。（超過一個小時）。當消息完成處理下面的行執行： self._channel.basic_ack(delivery_tag) 然而之後，我接收on_connection_closed事件，這會導致消費者我的重新連接。問題是確認未送達，並且已處理的消息被髮送給另一位消費者並再次處理。任何幫助將不勝感激。

4熱度

1回答

如何發送RabbitMQ消息給Pykka演員？

更新2015年8月：對於想要使用消息傳遞的人，我目前會推薦使用zeromq。可以用作pykka的補充或完全替代。我該如何聆聽RabbitMQ隊列中的消息，然後將它們轉發給Pykka中的演員？目前，當我嘗試這樣做時，我會發現奇怪的行爲，系統停下來停下來。這裏是我有我的演員來實現： class EventListener(eventlet.EventletActor): def __i

2熱度

1回答

如何在python中做一個簡單的Pika SelectConnection發送消息？

我試圖將我的代碼轉換爲通過皮卡發送rabbitmq消息。我很難理解如何使用異步連接發送簡單消息（如SelectConnection）。在我的舊代碼，這是我使用AMQP庫我簡單地聲明這樣的類： import amqp as amqp class MQ(): mqConn = None channel = None def __init__(self):

0熱度

1回答

Python Pika回調不能使用類內的SelectConnection

我想創建一個簡單的Python Pika SelectConnection，看來我無法使用on_open_callback打開連接，並且我也沒有從te on_open_error_callback獲取任何內容。有人可以提出可能導致問題的原因嗎？ import pika class RabbitmqTransport(object): def __init__(self):

0熱度

1回答

如何強制關閉客戶端連接rabbitmq

我有一個使用rabbitmq代理的客戶端服務器應用程序。客戶端連接到rabbitmq並將消息發送到服務器。在某些時候，如果服務器決定這個客戶端不應該連接到rabbitmq，我希望能夠從rabbitmq邊界強制斷開客戶端連接。請注意，在我的情況下，我不想發送消息到客戶端斷開連接，在服務器端我想強制從rabbitmq斷開此客戶端。無法找到api來執行此操作。任何幫助appriciated。