Совместное XMPP-соединение между работниками Celery

Question

Мое веб-приложение должно иметь возможность отправлять сообщения XMPP (чат Facebook), и я подумал, что Celery может быть хорошим решением для этого.Задача будет состоять из запроса базы данных и отправки сообщения XMPP нескольким пользователям.Однако при таком подходе мне придется подключаться к серверу XMPP каждый раз, когда я запускаю задачу, что не очень хорошая идея.

Из документов API чата Facebook :

Рекомендации

• Ваша интеграция с чатом Facebook должна использоваться только для сессий, которые, как ожидается, будут долгосрочными.Клиенты не должны быстро включать и выключать.

Существует ли способ обмена XMPP-соединением между работниками, поэтому мне не нужно переподключаться каждый раз, когда я хочу отправить сообщение?Или есть лучшее решение?

Answer 1

Вы можете создать соединение глобально в вашем модуле задач сельдерея и использовать его из ваших задач для отправки сообщений. В этом случае соединение будет установлено при запуске и будет разделено между рабочими процессами.

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?