kombu

    0熱度

    2回答

    從Python解釋器中複製並粘貼,但我試圖與Kombu一起玩,但似乎無法創建消費者。請幫助,我完全在這裏黑暗中。 >>> from kombu.messaging import Consumer, Producer >>> from kombu.entity import Exchange, Queue >>> x = Exchange("stmt",type="topic") >>> he

    0熱度

    1回答

    有沒有人用過pidbox.Mailbox? 我正在嘗試做類似的例子,但該文件是過時的方式。我設法得到一些信息發佈到Django交通工具,但從那裏他們從來沒有成功地收到。 我希望有人知道如何使用它,並且可以告訴我一個如何成功地調用/演員的例子。 這裏是我有什麼(虛擬節點真的什麼也不做只是打印或列表): #node/server mailbox = pidbox.Mailbox("test"

    0熱度

    1回答

    我進入全AMQP的事情,我有一個關於下使用哪種類型的交換類型的問題,以下情形的: 1)我有必要建立一個工作池,每個工人在收到消息時會做某些事情。現在我想讓不同的工作者參與不同類型的任務;我可以通過以主題方式使用每條消息的路由鍵來指定。在消費者端,與kombu玩一下我注意到,如果我指定相同的隊列名稱,但使用不同的路由鍵我不能「過濾」消息。例如,如果我有一個使用'#'的消費者,另一個使用'foo。#'