如何从django视图向消费者发送消息(django-channels)？

pip install channels

from channels.generic.websocket import AsyncWebsocketConsumer

class MyConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        await self.accept()

    async def disconnect(self, close_code):
        pass

    async def receive(self, text_data):
        # 处理接收到的消息
        await self.send(text_data='You sent: ' + text_data)

    async def send_message(self, event):
        # 处理从视图发送的消息
        await self.send(text_data=event['message'])

from django.urls import re_path

from . import consumers

websocket_urlpatterns = [
    re_path(r'ws/my_consumer/$', consumers.MyConsumer.as_asgi()),
]

# Channels设置
ASGI_APPLICATION = 'your_project_name.routing.application'
CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels.layers.InMemoryChannelLayer',
    },
}

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

def my_view(request):
    # 从请求中获取消息
    message = request.GET.get('message')

    # 获取Channel层
    channel_layer = get_channel_layer()

    # 向消费者发送消息
    async_to_sync(channel_layer.group_send)('my_group', {'type': 'send_message', 'message': message})

    return HttpResponse('Message sent to consumers')