Блог

Django 2.1.1, Django Channels 2.1.3, Celery 4.2.1

Я настроил задачу в Celery, и в конце задачи мне нужно отправить сообщение websocket клиенту (ам). Однако сообщение websocket никогда не отправляется. Ошибок не возникает, оно просто не отправляется.

Я настроил уровень канала, используя Redis в качестве серверной части. Выполнение этого из обычного представления Django работает нормально. Но при запуске в задаче Celery оно отправляет сообщение каналам, и я вижу, что каналы действительно выполняют код, показанный в моем consumers.py приведенный ниже код, но клиент никогда не получает сообщение websocket.

tasks.py

 def import_job(self):
    # (do task calculations, store in data dict)
    message = {'type': 'send_my_data',
               'data': json.dumps(thecalcs) }
    channel_layer = get_channel_layer()
    async_to_sync(channel_layer.group_send)('core-data', message)
  

consumers.py

 class AsyncDataConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.channel_group_name = 'core-data'

        # Join the group
        await self.channel_layer.group_add(
            self.channel_group_name,
            self.channel_name
        )
        await self.accept()

    async def disconnect(self, close_code):
        # Leave the group
        await self.channel_layer.group_discard(
            self.channel_group_name,
            self.channel_name
        )

    # Receive message from WebSocket
    async def receive(self, text_data=None, bytes_data=None):
        pass

    # Receive message from the group
    async def send_my_data(self, event):
        text = event['data']
        # Send message to WebSocket
        await self.send(text_data=text)
  

settings.py

 CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': {
            "hosts": [('127.0.0.1', 6379)],
        },
    },
}
  

Поскольку нет исключения / ошибки, я совершенно не понимаю, в какой части этого процесса происходит сбой.

1. Сельдерей запускает задачу? ДА
2. Задача запускается и отправляет сообщение на уровень канала? ДА
3. Потребитель получает сообщение от группы и выполняет send() ? ДА
4. Клиент получает сообщение websocket? НЕТ

Это проблема между каналами и Redis? Это проблема между каналами и клиентом?

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