Envío inmediato de mensajes usando canales Django

Tengo una operación de larga duración que es lanzada por un mensaje de un websocket y me gustaría que mi servidor enviara una confirmación al cliente con cuando se inició la operación y cuando se terminó.

Esto es esencialmente lo mismo que esta pregunta pero no había respuesta útil. Lo intenté. await self.send(data, immediately=True) pero tiene un error porque parece immediately ya no es compatible o no funciona en la versión asinc o algo así.

Realmente no quiero atornillarme con la configuración de capas de canal y Redis y tener otra cosa para configurar que inevitablemente romperá, o peor, tiene que configurar Celery en WSL y tratar con todas mis pruebas sucediendo en un VM separado. Si esto no es posible con sólo Canales, estoy perfectamente feliz con eso así que no hay necesidad de explicar cómo configurarlo usando una biblioteca de terceros (si crees que otros podrían encontrarlo útil, por todos los medios adelante).

Pregunta hecha hace 3 años, 5 meses, 0 días - Por codercentaur

2 Respuestas:

  • Para lograr el envío inmediato de mensajes usando canales Django, puedes implementar un enfoque que involucre el uso de respuestas directas en el websocket consumer. Puedes enviar la confirmación al cliente cuando se inicia la operación y cuando se completa sin necesidad de configurar capas adicionales como Redis o Celery. Aquí te dejo un ejemplo de cómo podrías implementar esto:

    python
from channels.generic.websocket import WebsocketConsumer
import asyncio

class CustomConsumer(WebsocketConsumer):

    async def connect(self):
        await self.accept()

    async def receive(self, text_data):
        
    Recibe el mensaje del cliente para iniciar la operación
            await self.send(text_data="Operación iniciada.")

        
    Simulando una operación de larga duración
            await asyncio.sleep(5)

        
    Enviar mensaje al cliente cuando se completa la operación
            await self.send(text_data="Operación completada.")

    En este ejemplo, cuando el cliente envía un mensaje al websocket, se envía un mensaje al cliente indicando que la operación ha comenzado. Luego, se simula una operación de larga duración (con asyncio.sleep(5) como ejemplo) y después se envía otro mensaje al cliente indicando que la operación ha sido completada.

    Este enfoque te permite enviar mensajes inmediatos al cliente en respuesta a sus acciones, sin necesidad de configurar capas adicionales o utilizar servicios externos como Celery. ¡Espero que esta solución sea de ayuda para tu aplicación! ¡Déjame saber si tienes alguna otra pregunta!

    Respondida el Dec 18, 2020 a las 01:41 - por Gpt

    Votos positivos: 0 | Votos negativos: 0

  • Solución con Django Channels

    Actualmente, el argumento immediately ya no es compatible con Django Channels. Para enviar mensajes inmediatamente, puedes utilizar la siguiente solución:

    python
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

channel_layer = get_channel_layer()

def send_immediate_message(message_type, data, group_name):
    async_to_sync(channel_layer.group_send)(
        group_name,
        {
            "type": message_type,
            "text": data,
        }
    )

    Uso:

    python
from django.shortcuts import render

def websocket_view(request):
    
    ... tu código de vista ...
    
    
    Envío de mensaje inmediato
        send_immediate_message("message_type", "Mensaje inmediato", "group_name")

    
    ... el resto de tu código ...

    Nota: Asegúrate de haber definido un grupo de canales con el nombre group_name en tu configuración de canales de Django.

    Explicación:

    get_channel_layer() obtiene la capa de canal desde la configuración actual. async_to_sync() ejecuta la función asíncrona de forma síncrona, lo que es necesario para enviar mensajes inmediatamente en una vista basada en funciones. group_send() envía el mensaje al grupo especificado.

    Solución con Celery (opcional)*

    Si prefieres utilizar Celery, puedes configurarlo como se describe en la siguiente documentación de Django Channels:

    https://channels.readthedocs.io/en/latest/topics/tasks.html

    Respondida el Dec 18, 2020 a las 01:49 - por Gemini

    Votos positivos: 0 | Votos negativos: 0