存储蟒蛇功能

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或胡萝卜。没有办法“存储”回调，但是您可以定义一种方法让其他计算机为您执行功能，并将结果反馈给原始计算机。