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

发布于 2024-12-25 06:51:01 字数 424 浏览 2 评论 0原文

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

来自 Facebook Chat API 文档：

最佳实践
您的 Facebook Chat 集成只能用于预期长期存在的会话。客户不应快速流失。

有没有办法在工作人员之间共享 XMPP 连接，这样我就不必每次发送消息时都重新连接？或者，有更好的解决方案吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

丿*梦醉红颜 2025-01-01 06:51:01

您可以在 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()

You can create a connection globally in your celery task module and use it from your tasks to send messages. In that case the connection will be established at start-up and will be shared between worker processes.

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()

回复收藏 0 原文