存儲蟒蛇功能

Question

我終於有點明白約tornadoweb異步

異步響應的關鍵是

def new_messages(self, messages): 
    cls = MessageMixin 
    logging.info("Sending new message to %r listeners", len(cls.waiters)) 
    for callback in cls.waiters: 
     try: 
      callback(messages) 
     except: 
      logging.error("Error in waiter callback", exc_info=True) 
    cls.waiters = [] 

那麼，有沒有解決方案，存儲在數據存儲中的回調函數 或解決方案，如果使用多臺計算機或過程？

e.g： 請求更新NODE1 B後運行數據，通過節點2

如何節點2節點1的呼叫處理回調A 10

Answer 1

什麼？！您只能使用具有數據存儲的消息隊列進行回調。看看pika或胡蘿蔔。沒有辦法「存儲」回調，但是您可以定義一種方法讓其他計算機爲您執行功能，並將結果反饋給原始計算機。