pika

0熱度

2回答

使用鼠兔BlockingConnection時，是否basic_ack（）必須放置在回調函數

說我已經到RabbitMQ的連接類似如下： connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost', 5672, '/', credentials)) channel = connection.channel() channel.queue_declare(queue=getting_fro

0熱度

1回答

將扭曲的消費者轉換爲服務

我正在嘗試將基於扭曲的pika（RabbitMQ）消費者轉化爲服務。這裏是什麼，我已經把目前發生的相關位： worker.py import pika from pika.adapters import twisted_connection from twisted.internet import defer, reactor, protocol, task @defer.inlineCa

0熱度

1回答

多進程兔子消費者

在此先感謝。我是多處理新手。我已經創建了一個流程，通過它我想同時使用數據槽Rabbit MQueue，但它一次運行一個進程。 def start_consum(queue_name): channel.basic_consume(func, queue=queue_name) channel.start_consuming() def process_start(num

4熱度

1回答

使用concurrent.futures一次消費很多出隊消息

我在使用RabbitMQ頻道的消息，我希望一次可以消費n個元素。我想我可以使用ProcessPoolExecutor（或ThreadPoolExecutor）。我只是想知道是否有可能知道是否有在池中自由執行。這是我想寫什麼： executor = futures.ProcessPoolExecutor(max_workers=5) running = [] def consume(mess

0熱度

1回答

丟棄rabbitmq消息沒有人在聽

我是rabbitmq消息傳遞的完全新手，如果這個問題很傻或者我的設置完全是梨形的，我很抱歉。我使用rabbitmq的設置是從某些探測器發送消息。每個探針都有一個唯一的名稱。然後我有一個集中的服務器來處理數據 - 如果有需要的話。我使用與探測器名稱相對應的直接交換和路由鍵。我宣佈我的客戶（服務器）如下（這是或多或少從RabbitMQ的教程）： connection = pika.Block

0熱度

1回答

RabbitMQ pika消費者取消後的異步消費者心跳問題

使用RabbitMQ和pika（python），我運行一個工作排隊系統，爲節點（異步消費者）提供任務。定義任務的每條消息只有在任務完成後纔會被確認。有時我需要在這些節點上執行更新，並且我創建了一個退出模式，節點等待任務完成，然後正常退出。然後我可以執行我的維護工作。爲了使節點在退出模式下不會從RabbitMQ獲得更多消息，我讓它在等待作業完成之前調用basic_cancel方法。這種方法的這

0熱度

1回答

需要使Python/Pika代碼穩健 - 不穩定的連接和高延遲

我正在使用Python和Pika庫將消息發佈到RabbitMQ服務器。下面的腳本將每30秒讀取一次文本文件的最後一行，然後將最後一行發佈到rabbitmq服務器。我的問題是，互聯網連接是非常不穩定的，並具有很高的延遲（600毫秒 - 800毫秒）。代碼將運行良好幾分鐘，但然後它開始拋出異常。最近的例外是： ERROR:pika.adapters.base_connection:Connectio

0熱度

1回答

限制連接到兔子隊列的數量？

我在ubuntu-16.04上使用pika-0.10.0與rabbitmq-3.6.6 broker。我設計了一個請求/回覆服務。有一個請求隊列，所有客戶端都會推送他們的請求。每個客戶端創建一個唯一的應答隊列：服務器將針對此客戶端的應答推送到此唯一隊列。我的API可以看作兩條消息：init和run。 init消息包含大圖像，因此init是一個大而緩慢的請求。 run信息較輕，服務器重用以前的圖像。

0熱度

1回答

如何檢測隊列已被刪除？

當我手動刪除我的PikaClient消耗隊列，沒有發生。我可以重新創建具有相同名稱的隊列，但通道已停止使用隊列（正常情況下，因爲我已將其刪除）。但是我希望在消耗的隊列被刪除時收到一個事件。我預計通道會自動關閉，但«on_channel_close_callback»永遠不會被調用。 «basic_consume»不提供關閉任何回調。另外重要的一點，我必須使用TornadoConnection。

0熱度

1回答

向EC2上的RabbitMQ服務器發送消息時出現連接錯誤

我在AWS EC2上運行我的RabbitMQ服務器我已經在本地運行生產者和使用者代碼。這是工作。我也可以訪問rabbitMQ管理web應用程序。當我想從我的筆記本電腦將數據推送到EC2 我收到這條線上此錯誤： connection = pika.BlockingConnection(pika.ConnectionParameters('xx.xx.xx.xx',5672,'/',creden