python-pika

    0熱度

    1回答

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

    0熱度

    1回答

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

    1熱度

    2回答

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

    0熱度

    2回答

    下面是功能正在使用擺脫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

    0熱度

    1回答

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

    1熱度

    1回答

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

    0熱度

    1回答

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

    0熱度

    1回答

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

    0熱度

    1回答

    相同的代碼可以在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回答

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