python-pika

0熱度

1回答

我有一個簡單的碼頭構建，我想實現。拉基本圖像odoo：9和安裝鼠庫 FROM odoo：9 RUN PIP安裝鼠，但無法繼續，因爲我得到這個錯誤。 enter image description here btw，我在Windows環境中使用docker。

0熱度

1回答

rabbitmq中的多個消費者爲多個隊列

我有2個隊列，比如說q1和q2，它對應於e1和e2與綁定密鑰b1和b2交換。我想要並行運行消費者功能，比如c1和c2，它們將分別監聽q1和q2。我試了下面的方法： def c1(): connection = pika.BlockingConnection(pika.ConnectionParameters(host=constants.rmqHostIp)) channel

1熱度

2回答

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

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

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(delivery_t

1熱度

1回答

Python - 在獨立線程中運行的函數之間傳遞函數（回調）變量

我正在嘗試開發一個使用pika和線程模塊的Python 3.6腳本。我有一個問題，我認爲是由我的A）是非常新的Python和編碼一般，和B）我不理解如何在函數之間傳遞變量時，他們在單獨的線程中運行，並已通過接收函數名稱末尾的括號中的參數。我認爲這是因爲當我不使用線程時，我可以簡單地通過調用接收函數名稱並提供要傳遞的變量，在括號中顯示一個基本示例如下： def send_variable():

0熱度

1回答

RabbitMQ - 套接字關閉異常 - Windows Server 2012

因此，我有一個發佈商正在使用計劃 python包來讀取文件中的數據和每隔5-10分鐘並將每行發佈到隊列中。在我一直在使用一些消費者喜歡的另一面： self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) self.channel = self.connection.channel

0熱度

1回答

Pika可以在Ubuntu上連接到RabbitMq，但不能在Centos上工作？

相同的代碼可以在Ubuntu上運行，而不是在Centos上運行！防火牆已關閉！ Ubuntu 16.04，python版本3.5.2。 Centos 7，python版本3.5.2。 Ubuntu和centos是virtualbox中新安裝的！ RabbitMq config tls！在Centos上，如果連接rabbitmq disable ssl是可以的，但是如果連接rabbitmq ena

0熱度

1回答

爲什麼這個全局變量在Python 2.7中更新，即使我使用全局關鍵字？

我有一個回調函數，它在收到每條消息時返回AMQP消息的主體。我希望能夠將正文的內容分配給全局變量，然後在我的程序中進一步處理它。我在腳本的頂部創建了一個全局變量，並且在回調函數中使用了global關鍵字，我知道應該允許我更新腳本頂部的全局變量，但是當我導入' 「從另一個腳本，我得到的原始值‘測試全局變量’返回，而不是身體的從回調函數中的當前值... Consumer.py **python/pi

1熱度

1回答

pika.BlockingConnection（）失敗容器內，在虛擬機內運行良好

我想在我的容器中使用rabbitmq。我安裝了所需的庫，然後嘗試創建BlockingConnection，但失敗。當我在任何虛擬機或物理主機上嘗試它時，也是如此。它僅以容器失敗。具體操作步驟如下： - 安裝所需的軟件包： - $ docker run -it ubuntu:15.10 /bin/bash [email protected]# [email protected]# sudo ap

1熱度

1回答

的Python 3.6：如何創建使用SelectConnection適配器鼠消費者不使用類？

我是新來的Python和鼠兔和我遇到了從使用BlockingConnection適配器，它保持了幾個小時後拋出異常隊列消耗的問題。我爲此嘗試使用SelectConnection（異步）適配器，但我只能找到在類中使用此適配器類型的示例，並且使用基於類的代碼稍微超出了我目前的理解範圍。我確實找到了一個例子，展示瞭如何使用SelectConnection創建一個生產者，但是我找不到一個消費者的例子，