pika

5熱度

1回答

我有一個Apache Spark羣集和一個RabbitMQ代理，我想使用pyspark.streaming模塊來使用消息並計算一些指標。的問題是我只找到this package，但在的Java和斯卡拉實現。除此之外，我還沒有在Python中找到任何示例或橋接實現。我有一個消費者實施使用Pika，但我不知道如何將有效載荷傳遞到我的StreamingContext。

1熱度

1回答

如果沒有服務器在運行，我應該如何中止客戶端？

如何檢查服務器是否正在監聽RPC客戶端服務器調用？ https://www.rabbitmq.com/tutorials/tutorial-six-python.html

4熱度

2回答

如何在用pika發佈消息時添加標題關鍵字：值對

我正在編寫一個自動測試來測試消費者。到目前爲止，我在發佈消息時不需要包含頭部，但現在我可以。而且它看起來像缺乏文檔。這是我的出版商： class RMQProducer(object): def __init__(self, host, exchange, routing_key): self.host = host self.exchange = excha

1熱度

4回答

無法使用pika連接到遠程rabbitmq服務器

我正嘗試使用pika連接到我的遠程rabbitmq，但我得到Connectionclosed（）錯誤。我已經在來賓用戶的rabbit.config中進行了必要的更改，以允許所有連接以及來自我的Java代碼的相同連接。我甚至嘗試創建一個擁有所有權限並連接它的新用戶，但它仍然不起作用。儘管我的本地主機相同的代碼工作正常。任何人都可以讓我知道我在這裏做錯了什麼？ def queue_message(me

3熱度

1回答

IncompatibleProtocolError嘗試連接到RabbitMQ的

我有使用鼠兔對dockerized的RabbitMQ Python代碼連接問題。我使用此代碼連接到隊列： @retry(wait_exponential_multiplier=1000, wait_exponential_max=10000, stop_max_attempt_number=2) def rabbit_connect(): connection_uri = cfg.g

1熱度

1回答

Rabbitmq與Pika遠程通話

我是rabbitmq的新手，並試圖弄清楚如何通過本教程（https://www.rabbitmq.com/tutorials/tutorial-six-python.html）向客戶端請求一個有關內存和CPU利用率信息的服務器。因此，客戶端請求CPU和內存（我相信我需要兩個隊列），服務器以這些值作爲響應。無論如何，簡單地創建一個client.py和server.py在這種情況下使用Python

0熱度

1回答

消耗兩個隊列rabbitmq pika python

我目前正在使用pika網站上提供的async示例消費者，並且想知道是否有可能讓一個消費者消費兩個隊列？ rabbitmq網站上的示例似乎僅適用於每個隊列的一位消費者。

1熱度

2回答

由於身份驗證錯誤，無法從網絡上的其他客戶端訪問RabbitMQ服務器

我在Ubuntu 14.04上安裝了RabbitMQ，並且無法從網絡上的其他計算機連接到RabbitMQ服務器。從安裝了RabbitMQ的機器連接到服務器時，沒有任何問題，只能從網絡上的其他計算機連接到服務器。 This page指出「默認情況下，RabbitMQ將在所有可用接口上監聽端口5672」。當試圖從另一個serverusing鼠兔在python連接，我收到以下錯誤： ERROR:pi

1熱度

1回答

有沒有辦法將RabbitMq配置爲在錯過心跳後未關閉連接？

有沒有辦法配置RabbitMq在錯過心跳後根本不關閉連接？

1熱度

2回答

如何重新啓動消費者rabbitmq pika python

我正在使用rabbitmq的pika庫設置的消費者正在經歷一些輟學。與pika一起，我正在使用扭曲的實現來設置異步消費者。我不知道爲什麼會發生這種情況，但如果消費者退出並且不確定如何去做，我希望實施重新連接。這是我當前的實現 class Consumer(object): def __init__(self, queue, exchange, routingKey, medium, signal