pika

    7熱度

    1回答

    阻止jupyter筆記本單元執行到收到特定消息

    我試圖爲python實現異步，分佈式計算引擎，它與jupyter筆記本兼容。該系統應該基於「推送通知」方法，使得用戶無法等待特定的計算結果（即，直到具有預期結果的消息被遞送爲止），使得它（幾乎我希望）不可能等待特定的計算結果。準確地說，我想： 添加新的任務jupyter筆記本事件循環（任務定期檢查是否存在特定的味精已經抵達while循環，休息時味精到達） 阻止當前單元格等待任務完成。 依然能夠處理
    python rabbitmq jupyter-notebook python-asyncio pika 2017-10-10

    -2熱度

    1回答

    嘗試連接到遠程RabbitMQ服務器時出現AccessDeniedError

    我試圖用兩個主機連接RabbitMQ & python pika。 這裏是工人： #!/usr/bin/env python import pika, time NEW_TASK_HOST_IP = '192.168.0.2' credentials = pika.PlainCredentials('login-to-remote', 'pass') connection = pika.B
    python rabbitmq rpc pika 2017-10-12

    0熱度

    1回答

    由孩子繼承的Python RabbitMQ連接

    問題如下。 調用一個執行兩件事情的Python程序：連接到rabbitmq服務器並調用產生兩個進程的c程序。 當python程序結束時，連接仍然建立在負責孩子。 因此，當父母死亡時，孩子會繼承其父資源。 做netstat -putan | grep rabbitmqip tcp 0 0 localhost:39744 rabbitmqip:5672 ESTABLISHED 25693/child
    python c rabbitmq fork pika 2017-07-06

    1熱度

    1回答

    Python ActiveMQ：是否有可能使用pika客戶端來處理ActiveMQ？

    據我所知ActiveMQ支持amqp://協議，現在我想連接python中的ActiveMQ實例。 是否可以使用pika包來獲得它？當我讀到pika的文件時，它似乎只是與RabbitMQ一起使用而設計的。 否則，我應該使用哪種協議最適合於Python上的ActiveMQ？
    python rabbitmq activemq amqp pika 2017-09-03

    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
    python rabbitmq pika python-pika 2017-07-16

    1熱度

    1回答

    保持鼠BlockingConnection活着沒有禁用心跳

    我正在開發一個RabbitMQ的消費與鼠兔0.10.0和Python 2.7 version.In我消費的客戶，我有對依賴於輸入消息的時間段運行的進程。它可以從3到40分鐘不等。 我不想禁用心跳。相反，我正在尋找一些可以保持連接活動的collback機制，直到delivery_tag被髮回。那可能嗎？ 很少聯繫我，一切都暗示禁用心跳的解決方法。但我不想禁用它。 編號： Socket Error:
    python-2.7 rabbitmq pika 2017-09-05

    0熱度

    1回答

    如何刪除rabbitmq中的消息（pika）

    如何刪除發佈和接收的消息，在rabbitmq 我正在用python測試rabitmq，同樣的消息還在繼續發佈和接收，如何避免這種情況。 我怎樣才能刪除公佈並收到
    python rabbitmq pika 2017-12-18

    0熱度

    1回答

    socket.gaierror gaierror：[Errno -2]名稱或服務未知 - pika rabbitMQ

    我試圖從託管在本地主機上的python服務器發送消息：5000到RabbitMQ服務器（使用Docker鏡像的RabbitMQ），但我收到以下錯誤： socket.gaierror gaierror: [Errno -2] Name or service not known 我使用的，其中「rabbithost」是我使用的主機名命令運行的泊塢窗圖像的RabbitMQ： sudo docker ru
    python sockets docker rabbitmq pika 2017-09-13

    0熱度

    1回答

    pika.exceptions.ConnectionClosed：連接到172.18.0.3:5672失敗：[Errno 111]連接被拒絕

    我試圖連接一個Pika客戶端與RabbitMQ服務器。他們都在不同的碼頭圖像上，他們在同一個碼頭網絡上。 設置我的網絡 docker network create my_first_net 我運行的是RabbitMQ的圖像rabbitmq作爲 docker run -d --network my_first_net --hostname rabbitmqhost -p 35672:15672
    docker rabbitmq pika 2017-09-14

    0熱度

    1回答

    處理pika.exceptions.BodyTooLongError

    我的RabbitMQ監聽器已經開始提升pika.exceptions.BodyTooLongError異常。我從來沒有見過他們。 Google對此錯誤及其原因幾乎沒有透露。 回溯錯誤消息我得到的是： 'NoneType' object has no attribute 'body_size' Traceback (most recent call last): File "./foo.
    python rabbitmq pika 2017-06-15
最新問題