Celery工作者之间的共享XMPP连接

Question

我的网络应用程序需要能够发送XMPP消息(Facebook聊天),我认为Celery可能是一个很好的解决方案.任务包括查询数据库并将XMPP消息发送给许多用户.但是,使用这种方法,每次运行任务时都必须连接到XMPP服务器,这不是一个好主意.

来自Facebook Chat API文档:

最佳实践

• 您的Facebook聊天集成应仅用于预期长期存在的会话.客户不应该快速流失.

有没有办法在工作人员之间共享XMPP连接,所以每次我想发送消息时都不需要重新连接？或者,有更好的解决方案吗？

Answer 1

您可以在 celery 任务模块中全局创建连接，并在任务中使用它来发送消息。在这种情况下，连接将在启动时建立，并将在工作进程之间共享。

import socket 
from celery.task import task

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
s.connect(('localhost', 9999)) 

@task
def echo(arg):
    s.send(arg) 
    return s.recv()