Как я могу поделиться экземпляром класса, созданного в моем приложении, с помощью celery Beat ⇐ Python

[Anonymous]

У меня есть приложение, которое использует веб-сокеты, я управляю соединениями с помощью Python, вот код, в котором я управляю своими веб-сокетами, он работает в контейнерах докеров:

Код: Выделить всё

ws_router = APIRouter()

class ConnectionManager:

def __init__(self):
self.active_sockets = {}
self.disconnected_sockets = {}

async def connect(self, websocket: WebSocket):
client_ip = websocket.client.host

self.active_sockets[websocket] = {
"client_ip": client_ip
}

await websocket.send_json({
"action": "send_id",
"socket_id": socket_id
})
self.print_conn()

def print_conn(self):
print(f"active: {self.active_sockets}")
print(f"disco: {self.disconnected_sockets}")

def disconnect(self, websocket: WebSocket):

if websocket in self.active_sockets:
data = self.active_sockets[websocket]

self.disconnected_sockets[data["socket_id"]] = data

del self.active_sockets[websocket]

self.print_conn()

def clean_disconnections(self):
self.print_conn()

manager = ConnectionManager()

@ws_router.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
await manager.connect(websocket)
ping_task = asyncio.create_task(manager.enviar_ping(websocket))
while True:
data = await websocket.receive_json()
await handle_data(data, websocket)

мне нужно использовать сельдерей для очистки соединений каждый час, поэтому я настроил такт сельдерея:

Код: Выделить всё

celery = Celery("celery")

celery.conf.broker_url = os.environ.get("CELERY_BROKER_URL")
celery.conf.result_backend = os.environ.get("CELERY_RESULT_BACKEND")
celery.conf.timezone = 'America/Mexico_City'
celery.conf.enable_utc = False
celery.conf.beat_schedule = {
'clean_connections': {
"task": "clean_connections",
"schedule": crontab(minute=24),
"options": {'queue': 'cleaner'}
}
}

#@celery.task(name=)

@shared_task(name='clean_connections')
def clean_connections():
manager.clean_disconnections()

Когда я запускаю свой проект, я подключаюсь к сокету, и мой журнал приложений показывает соединения, но когда работает celery beat, журнал сельдерея показывает только пустой объект, как я могу поделиться эта память
Я пытался переключиться на задачу и поделиться задачей, а также использовать глобальные переменные, но она все равно печатает тот же пустой объект

Подробнее здесь: https://stackoverflow.com/questions/791 ... elery-beat