Python-сообщество

wofir · Май 31, 2015 16:09:08

у меня есть небольшой сокет-сервер на tornado:

class SocketHandler(tornado.websocket.WebSocketHandler):
    connections = []
    
    def open(self):
        self.__class__.connections.append(self)
    
    @classmethod
    def get_connections(cls):
        return cls.connections

и celery таск, который должен отправлять сообщения клиентам:

from handlers import SocketHandler
    
@celery.task
def send_msg(msg):
    for conn in SocketHandler.get_connections():
        conn.write_message(msg)

Но список полученный путем SocketHandler.get_connections() в файле с celery тасками оказывается пустым.
tornado сервер запускаю так:

(venv)$ python app.py

а celery воркеры запускаю в другом терминале так:

(venv)$ celery -A tasks worker

Подскажите, пожалуйста, что я делаю не так и как мне получить список с соединениями в функции для celery

Отредактировано wofir (Май 31, 2015 16:10:41)

Python-сообщество

Уведомления

#1 Май 31, 2015 16:09:08

Получить список сокет соединений из функции для celery

Board footer