pika

    0熱度

    2回答

    Rabbitmq權限

    我正在使用python的rabbitmq權限。該應用程序有多個客戶端和一個服務提供者。我想限制客戶端到特定的隊列，而服務提供者應該能夠讀取所有隊列而不寫入任何隊列。我嘗試設置權限如下： 對於服務提供商的帳戶，我設置了以下 rabbitmqctl set_permissions -p vhost service_provider ".*-client-queues" "" ".*-client-qu
    rabbitmq pika 2014-03-28

    4熱度

    2回答

    由於ProbableAccessDeniedError無法連接到Heroku上的RabbitMQ

    我剛剛在heroku中設置了一個RabbitMQ插件。在開發我的應用程序以排隊並使用在本地實例上運行的消息後，我將其部署到Heroku，並且尚未能成功連接。用戶名/密碼& hostname/port/vhost全部來自heroku config。如果我更改用戶名或密碼，錯誤更改爲ProbableAuthenticationError，這使我相信身份驗證至少是正確的，但可能是我的虛擬主機或其他某些缺
    python heroku rabbitmq pika 2014-09-02

    3熱度

    2回答

    pika發送郵件到rabbitmq超時

    當試圖從筆記本電腦發送消息到另一臺筆記本電腦與pika和rabbitmq我得到這個錯誤。任何想法如何解決這個問題？ WARNING:pika.adapters.base_connection:Could not connect due to "timeout," retrying in 2 sec ERROR:pika.adapters.base_connection:Could not con
    python python-2.7 rabbitmq pika 2014-02-16

    0熱度

    1回答

    使用pika將所有消息從一個隊列重新排列到另一個隊列

    我需要循環回調隊列中的所有消息，然後關閉回調。我需要它在隊列清空後停止使用。 因此，我正在將消息從一個隊列寫入另一個隊列。 creds = pika.PlainCredentials(app.config['mq.user'], app.config['mq.pass']) connection = pika.BlockingConnection(pika.ConnectionParameters
    python queue rabbitmq pika 2014-09-04

    4熱度

    1回答

    在python中使用rabbitmq時出現「pika.exceptions.ConnectionClosed」錯誤

    我在：http://www.rabbitmq.com/tutorials/tutorial-two-python.html中使用「hello world」教程。 worker.py看起來像這樣 import pika import time connection = pika.BlockingConnection(pika.ConnectionParameters( host='
    python rabbitmq pika 2014-02-27

    1熱度

    1回答

    右鍵取消rabbitmq消費pika

    我想使用rabbitmq來實現rpc客戶端。我的代碼主要看起來像 def start(self): while True: self.channel.basic_consume(self.on_delivery) ... client.start() // blocking call 停止此客戶端的正確方法是什麼？ 現在我從另一個線程製作channel.basic_c
    python rabbitmq amqp pika 2014-03-04

    3熱度

    3回答

    由於某種原因在一段時間後關閉rabbitmq連接

    我使用pika python庫連接到本地主機上的rabbitmq-server。 class BaseRabbitSender(MessageSender): __metaclass__ = ABCMeta def __init__(self, host): self.node = BaseMessagingNode(host) self.connec
    python rabbitmq pika 2014-03-05

    0熱度

    1回答

    RabbitMQ消息/主題接收器在RabbitMQ未運行時崩潰

    我在linux OS環境中使用python和pika。 消息/主題當RabbitMQ未運行時，Receiver不斷崩潰。 我想知道是否有一種方法可以在RabbitMQ不是因爲RabbitMQ不會與消息/主題接收器位於同一虛擬機上時保持郵件/主題接收器運行。 如果RabbitMQ由於某種原因崩潰，但消息/主題接收器應繼續運行，則此封面。保存必須再次啓動/重新啓動消息/主題接收器。
    python rabbitmq pika 2014-03-06

    0熱度

    1回答

    通過rabbitmq服務器發佈和訂閱

    我需要一個節點發送消息並且另一個節點開始等待獲取消息的場景。 收到消息後，每個節點變成監聽器，收到消息後它又變成發佈者。
    python-2.7 rabbitmq pika python-pika 2014-01-16

    5熱度

    1回答

    Pika python異步發佈者：如何通過控制檯從用戶發送數據？

    我正在使用標準的異步發佈者示例。我注意到發佈者會一直在循環中發佈相同的消息。 所以我評論了來自publish_message的schedule_next_message調用來停止該循環。 但我真正想要的是publissher開始和發佈只有當用戶給它一個「message_body」和「密鑰」 基本上發佈者發佈用戶輸入。 我無法找到任何有關如何讓發佈商實時獲取用戶輸入的示例或提示。 我是新來raabi
    python asynchronous pika 2014-03-07
最新問題