Django Signals+Channels异常：模型save触发的消息无法传至客户端

我帮你梳理下导致post_save信号触发的消息无法传递到WebSocket客户端的几个关键问题，一步步来解决：

1. Consumer中消息字段匹配错误 #

这是最直接的问题：在你的信号处理函数save_post里，发送给频道组的消息结构是{"type": "stream", "data": json_data}，但在StreamConsumer的stream方法中，你错误地尝试读取event["message"]——这个字段根本不存在！

你需要把event["message"]改成event["data"]，对应信号里发送的字段名。

修正后的Consumer代码：

from channels.generic.websocket import AsyncWebsocketConsumer  # 导入正确的基类

class StreamConsumer(AsyncWebsocketConsumer):
    groups = ["echo_group"]
    
    async def websocket_connect(self, event):
        print("connected", event)
        await self.send({
            "type": "websocket.accept"
        })
    
    async def stream(self, event):
        # 修正：读取正确的字段名data
        data = event["data"]
        await self.send({
            'type': 'websocket.send',
            'text': data
        })

2. 更换为更合适的WebSocket Consumer基类 #

你之前用的AsyncConsumer是Channels的通用异步消费者，而专门的AsyncWebsocketConsumer是为WebSocket场景设计的，它封装了更多WebSocket相关的逻辑，能避免一些潜在的兼容问题，所以建议替换成这个基类（上面的代码已经做了替换）。

3. 确认WebSocket路由配置（隐藏的必要检查） #

虽然你没提供路由代码，但必须确保你的WebSocket路由正确指向了StreamConsumer，否则消息也无法正确路由到客户端。

示例路由配置（参考） #

在项目的routing.py中添加：

from django.urls import re_path
from . import consumers

websocket_urlpatterns = [
    # 匹配你前端使用的/websockets/路径
    re_path(r'websockets/$', consumers.StreamConsumer.as_asgi()),
]

然后在项目根目录的asgi.py中集成Channels路由：

import os
from django.core.asgi import get_asgi_application
from channels.routing import ProtocolTypeRouter, URLRouter
from . import routing

os.environ.setdefault('DJANGO_SETTINGS_MODULE', '你的项目名.settings')

application = ProtocolTypeRouter({
    "http": get_asgi_application(),
    # 配置WebSocket路由
    "websocket": URLRouter(routing.websocket_urlpatterns),
})

验证方法 #

1. 修正代码后重启Django服务
2. 通过创建DeribitFundingData实例触发save信号（比如在shell中执行DeribitFundingData.objects.create(time=datetime.now(), rate=0.001)）
3. 查看前端浏览器控制台，应该能看到WebSocket接收到的消息

另外，你可以在save_post函数中添加print(json_data)，确认信号确实被触发且数据正确生成，这样可以排除信号本身的问题。

内容的提问来源于stack exchange，提问作者Filipe Aleixo