Django环境传感器API：如何获取并返回传感器最新值？

核心问题梳理 #

1. update_latest_value函数逻辑错误：
   • 原函数试图通过Sensor.objects.filter(value=val).latest("timestamp")查询最新值，完全不符合业务逻辑——应该从传感器的历史数据（而非Sensor自身）获取最新值，且参数val无实际意义。
   • 该函数从未被调用，导致Sensor的value和timestamp始终为null。
2. 视图查询字段错误：StationSensorList中Sensor.objects.filter(sensor_station=station_id)的字段名错误，Sensor模型的外键是station，不是sensor_station。
3. 数据模型设计缺失：从views导入SensorValue可知，应该用独立模型存储传感器历史数据，而非把最新值和基础信息混存在Sensor中。

具体修复步骤 #

1. 完善数据模型（models.py） #

添加SensorValue模型存储历史数据，并修正update_latest_value函数：

from django.db import models
from django.db.models.signals import post_save
from django.dispatch import receiver

class SensorStation(models.Model):
    name = models.CharField(max_length=100, unique=True)
    location = models.CharField(max_length=100)

    def __str__(self):
        return self.name

class Sensor(models.Model):
    sensor_type_choices = [
        ("TEMP", "Temperature"),
        ("HUMID", "Humidity"),
        ("LIGHT", "Light"),
    ]
    sensor_unit_choices = [
        ("Celsius", "Cel"),
        ("Humidity", "hmd"),
        ("Light", "lgt")
    ]

    name = models.CharField(max_length=100)
    sensor_type = models.CharField(max_length=5, choices=sensor_type_choices)
    sensor_unit = models.CharField(max_length=15, choices=sensor_unit_choices)
    station = models.ForeignKey(SensorStation, on_delete=models.CASCADE)
    value = models.DecimalField(max_digits=5, decimal_places=2, null=True, blank=True)
    timestamp = models.DateTimeField(null=True, blank=True)

    def __str__(self):
        return f"{self.name} ({self.get_sensor_type_display()})"

    def update_latest_value(self):
        # 从关联的历史数据中获取最新值
        latest_value = self.values.first()
        if latest_value:
            self.value = latest_value.value
            self.timestamp = latest_value.timestamp
        else:
            self.value = 21.21  # 调试默认值
            self.timestamp = None
        self.save()

# 新增：存储传感器历史数据的模型
class SensorValue(models.Model):
    sensor = models.ForeignKey(Sensor, on_delete=models.CASCADE, related_name='values')
    value = models.DecimalField(max_digits=5, decimal_places=2)
    timestamp = models.DateTimeField(auto_now_add=True)

    class Meta:
        ordering = ['-timestamp']  # 按时间倒序，first()直接取最新

# 信号：新增历史数据时自动更新传感器最新值
@receiver(post_save, sender=SensorValue)
def update_sensor_latest(sender, instance, created, **kwargs):
    if created:
        instance.sensor.update_latest_value()

2. 修正视图查询字段（views.py） #

修复StationSensorList中的过滤字段：

class StationSensorList(generics.ListCreateAPIView):
    serializer_class = SensorSerializer

    def get_queryset(self):
        station_id = self.kwargs["pk"]
        return Sensor.objects.filter(station=station_id)  # 替换sensor_station为station

    def perform_create(self, serializer):
        station_id = self.kwargs["pk"]
        sensor_station = SensorStation.objects.get(id=station_id)
        serializer.save(station=sensor_station)  # 同步修改外键字段名

3. 确保序列化时更新最新值（可选） #

如果希望每次API返回数据都确保值是最新的，可在序列化器中触发更新：

# serializers.py
from rest_framework import serializers
from .models import Sensor

class SensorSerializer(serializers.ModelSerializer):
    class Meta:
        model = Sensor
        fields = ['id', 'name', 'sensor_type', 'sensor_unit', 'station', 'value', 'timestamp']

    def to_representation(self, instance):
        instance.update_latest_value()
        return super().to_representation(instance)

验证修复 #

1. 运行数据库迁移：python manage.py makemigrations 和 python manage.py migrate
2. 新增一条SensorValue数据关联目标传感器
3. 调用Sensor API，此时value和timestamp应返回最新的历史值

内容的提问来源于stack exchange，提问作者Gerasimos Papanikolaou