python - Celery 工作人员之间共享 XMPP 连接

Question

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

来自Facebook 聊天 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()

Answer 2

一个长期运行的后台作业如何，它的工作是接收来自其他短期进程的消息并将它们推送到 XMPP 套接字上？