Как в контексте синхронной джанги заставить channels отправлять сообщения в реальном времени?

Question

[NyxDeveloper]

Всем привет!
Делаю одно web-приложение, в котором один процесс приходится очень долго ждать. Решил, что можно повесить на прогресс channels веб-сокет, но дело в том, что все сообщения в сокет приходят только после возвращения ответа с сервера, что делает такой индикатор прогресса бесполезным.
Можно ли как-нибудь заставить метод channels_layer.send/group_send отправить сообщениев сокет до получения ответа от сервера?

Comments

[serhiops]

Покажите, пожалуйста, код.

[NyxDeveloper]

serhiops, Вот основной код без лишнего

channel_layer = get_channel_layer()

class GetRecalculate(APIView):
    def post(self, request):
        parameters = get_search_parameters(request)
        filepath = get_recalculate(request.FILES['file'], **parameters)
        return FileResponse(open(filepath, 'rb'), as_attachment=True, filename='Пересчет ASIST.xlsx')

def send_progress(token: str, progress_data: dict):
    text_data = json.dumps(progress_data, cls=encoders.JSONEncoder, ensure_ascii=False)
    async_to_sync(channel_layer.group_send)(
        f"progress-{token}", {"type": "progress", "message": text_data}
    )

def get_recalculate(f, *args, **kwargs):
    ...
    send_progress(kwargs["token"], progress_data)
    ...
    send_progress(kwargs["token"], progress_data)
    ....
    return recalculate

Вот consumers.py

class ProgressConsumer(WebsocketConsumer):

    def connect(self):
        self.room_name = self.scope["url_route"]["kwargs"]["token"]
        self.room_group_name = f"progress-{self.room_name}"
        async_to_sync(self.channel_layer.group_add)(self.room_group_name, self.channel_name)
        self.accept()

    def disconnect(self, close_code):
        async_to_sync(self.channel_layer.group_discard)(self.room_group_name, self.channel_name)

    def receive(self, text_data=None, bytes_data=None):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']
        async_to_sync(self.channel_layer.group_send)(self.room_group_name, {
            'type': text_data_json["type"],
            'message': message
        })

    def progress(self, event):
        self.send(text_data=event["message"])

Answer 1

[Rodion]

Привет

Ответ на основной вопрос - да, можно. Но придётся понять для себя как работает эта связка Django + Channels, чтобы данные по каналу с сервера отправлялись асинхронно.

Если вкратце: подключить channels_redis, в своём Consumer'е реализовать метод-обработчик, который будет получать извне данные и отправлять их в действующий websocket канал, и реализовать постоянно-работающую службу (в зависимости от того как вы отправляемые данные подготавливаете; например, celery worker), которая, подготовив данные, отправит их через group_send(), который, в свою очередь, положит данные в Redis, а Consumer, с обратной стороны, вытащит их и передаст в тот самый метод-обработчик.

Сперва голова кругом от такой логики, но всё очень продуманно и нужно только время на понимание процессов.

Comments

[NyxDeveloper]

Да, я на самом деле так и подумал в первую очередь. Я настроил channels_redis, поставил задачку отправки логов в celery, запустил воркер и ожидал, что все будет работать именно так, однако, логика на мое удивление не изменилась. Но ничего, из ситуации я вышел, просто поднял на соседнем порту еще один сервис, который отвечает за прогресс выполнения чего угодно, теперь основной сервер хукает его, а он в свою очередь отсылает сообщение в сокет. Может и костыль, зато работает как я хотел, потом проброшу через nginx на один порт)))