如何通过Django post_save信号将模型保存数据发送到WebSocket？

嘿，其实你完全不用去查询索引最大的记录——post_save信号里的instance参数就是你刚调用.save()保存的那个对象实例啊！这才是最优雅、最高效的解决方案，不用额外查数据库，直接用它就行。

给你两种实现方式，根据你的场景选：

方案1：手动构造数据字典（适合简单模型） #

如果你的模型字段不多，直接从instance里提取字段值构造字典就行，注意把DateTimeField转成前端能解析的字符串格式：

def save_post(sender, instance, **kwargs):
    channel_layer = get_channel_layer()
    # 从刚保存的instance中提取数据
    data = {
        "id": instance.id,
        "time": instance.time.isoformat(),  # 把datetime转成ISO标准字符串
        "value": instance.value
    }
    async_to_sync(channel_layer.group_send)(
        "echo_group",
        {"type": "on.message", "data": data},
    )

方案2：用Django REST Framework序列化器（适合复杂模型） #

如果模型字段多或者需要更规范的序列化逻辑，用DRF的ModelSerializer会更省心，它会自动处理字段类型转换：

首先在你的app下创建serializers.py，定义序列化器：

from rest_framework import serializers
from .models import DataModel

class DataModelSerializer(serializers.ModelSerializer):
    class Meta:
        model = DataModel
        fields = ["id", "time", "value"]  # 指定要序列化的字段

然后在信号函数里使用这个序列化器：

from .serializers import DataModelSerializer

def save_post(sender, instance, **kwargs):
    channel_layer = get_channel_layer()
    # 序列化刚保存的instance，得到可直接发送的字典数据
    serializer = DataModelSerializer(instance)
    data = serializer.data
    async_to_sync(channel_layer.group_send)(
        "echo_group",
        {"type": "on.message", "data": data},
    )

补充说明 #

• post_save信号触发时，instance就是刚刚完成保存（或更新）的对象，它的状态是最新的，完全没必要再去数据库查一遍最大索引的记录，既浪费性能又可能出现并发场景下的误差。
• 对于DateTimeField，必须转换成字符串才能通过WebSocket传输（JSON不支持原生datetime类型），isoformat()是通用的转换方式，前端也能轻松解析成日期对象。

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