python-pika

    0熱度

    1回答

    我需要一個節點發送消息並且另一個節點開始等待獲取消息的場景。 收到消息後,每個節點變成監聽器,收到消息後它又變成發佈者。

    0熱度

    5回答

    我安裝了蟒蛇鼠兔在Mac上運行時, sudo pip install pika==0.9.8 我請確保安裝,這是試圖重新安裝時的響應, Requirement already satisfied (use --upgrade to upgrade): pika==0.9.8 in /usr/local/lib/python2.7/site-packages 但當我輸入一個*的.py我得到,

    1熱度

    1回答

    我有一個RabbitMQ Server設置,我使用Python-Pika獲取消息。問題是如果我啓用persistent delivery mode,並且工作人員無法處理消息。除了釋放消息之外,它會一直保留它直到消息,直到RabbitMQ連接重置。 有沒有辦法確保自動處理失敗的消息在合理的時間範圍內從可用的工作人員(包括同一工作人員)再次拿起? 這是我當前的代碼 if success: c

    3熱度

    2回答

    我已經機 客戶端和RabbitMQ的在同一個網絡 的RabbitMQ有許多客戶在運行上運行的兔MQ 我可以ping客戶端from rabbitMQ and back 機器間測量的最長延遲時間爲12.1 ms 網絡詳細信息:標準交換機網絡(運行在單個物理機上的虛擬機的網絡 - 用vmware VC)初始化RPC連接 /usr/lib/python2.6/site-packages/pika-0.9.

    0熱度

    1回答

    這可能是一個關於python回調的問題,與使用pika一樣多。我試圖開發一些訂閱RabbitMQ中的隊列的代碼,處理任何傳遞消息的有效負載,然後將該有效負載寫入一系列(磁盤)文件。因此,使用簡單的「Hello World」示例http://www.rabbitmq.com/tutorials/tutorial-one-python.html,我已將邏輯添加到回調函數(即偶然地稱爲「回調」)中,以將