Django 异步信号与 Channels Layer 深度集成

利用 Django 3.0+ 异步信号与 Channels 自定义层，构建实时事件驱动的非阻塞工作流，区别于普通异步视图教程。 · 难度：入门 · +10XP

Django 异步信号与 Channels Layer 深度集成

常规教程只教你使用接收/发送信号。本课程将演示如何编写异步信号处理器（使用 asyncio），并在其中通过 Channels 的 group_send 推送实时消息到 WebSocket 客户端。同时，将介绍如何自定义一个 Redis Sentinel 高可用的 layer 实现，保证信号触发后的事件不会丢失，适用于订单状态变更实时通知等场景。

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
from django.db.models.signals import post_save
from django.dispatch import receiver
from myapp.models import Notification
@receiver(post_save, sender=Notification)
async def async_notification_handler(sender, instance, **kwargs):
    channel_layer = get_channel_layer()
    await channel_layer.group_send(
        f'user_{instance.user.id}',
        {'type': 'notify', 'content': instance.text}
    )