Отправка сообщений в группы с использованием group_send() внезапно перестает работать через некоторое время. Метод-обработчик потребителя больше не вызывается.
Перезапуск daphne на некоторое время решит проблему.
Подробности
Никаких ошибок в журналах нет, просто сообщения больше не обрабатываются потребителями.
Я использую следующие библиотеки:
- aioredis == 1.2.0
- asgiref == 2.3.2
- каналы-redis == 2.3.2
- каналы == 2.1.6
- дафна == 2.2.4
- django == 2.1.5
- Redis == 3.0.1
Код
# settings.py
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {"hosts": [("localhost", "6379")]},
}
}
# views.py
class ReceiveEventView(APIView):
def post(self, request, *args, **kwargs):
# payload: {"type": "event_triggered", "group": "warning", "message": "Button pressed"}
# or
# payload: {"type": "event_triggered", "group": "danger", "message": "Red Button pressed"}
payload = json.loads(request.POST.get("payload", "{}"))
if (payload.get("type") == "event_triggered"):
async_to_sync(channel_layer.group_send)(payload.get("group"), payload)
return HttpResponse(status=204)
# consumers.py
class EventConsumer(WebsocketConsumer):
def connect(self):
if not self.scope["user"].is_authenticated:
return
self.accept()
for group in get_subscriptions(self.scope["user"]):
async_to_sync(self.channel_layer.group_add)(group, self.channel_name)
def disconnect(self, close_code):
if not self.scope["user"].is_authenticated:
return
for group in get_subscriptions(self.scope["user"]):
async_to_sync(self.channel_layer.group_discard)(group, self.channel_name)
def event_triggered(self, event):
logger.debug("Consumer::event_triggered()")
self.send(text_data=json.dumps(event))
ожидаемые и фактические результаты
Некоторое время Consumer::event_triggered() появляется в логе, но внезапно останавливается. Получение сообщений из браузера через WebSocket по-прежнему работает. Просто транспорт от group_send() до потребителей сломан.
