如何在 django 中获取按相关模型分组的具有最高价值的模型？

Question

我想在 django 中执行这个查询：

For each sensor, select it's latest message

在 SQL 中是这样的

SELECT * FROM (SELECT * FROM messages order by date_entered DESC) as order GROUP BY sensor_id

模型是这样定义的

class BaseModel(models.Model):
    id = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False)
    date_entered = models.DateTimeField(auto_now_add=True)
    date_modified = models.DateTimeField(auto_now=True)
    deleted = models.IntegerField(default=0)

    class Meta:
        abstract = True
        ordering = ['date_modified']

class Device(BaseModel):

    user =              models.ForeignKey(User, on_delete=models.SET_NULL, blank=True, null=True)

    name =              models.CharField(max_length=255, blank=False)
    identifier =        models.CharField(max_length=31, blank=False)
    imei =              models.CharField(max_length=31, blank=False)
    status =            models.CharField(max_length=31, blank=False)
    settings =          models.TextField()


class DeviceMessage(BaseModel):


    device =            models.ForeignKey(Device, on_delete=models.SET_NULL, blank=True, null=True)
    user =              models.ForeignKey(User, on_delete=models.SET_NULL, blank=True, null=True)

    latitude =          models.DecimalField(max_digits=9, decimal_places=6, blank=True, null=True)
    longitude =         models.DecimalField(max_digits=9, decimal_places=6, blank=True, null=True)
    altitude =          models.DecimalField(max_digits=7, decimal_places=2, blank=True, null=True)
    signal_strength =   models.DecimalField(max_digits=5, decimal_places=2, blank=True, null=True)
    battery =           models.DecimalField(max_digits=5, decimal_places=2, blank=True, null=True)

    satellites =        models.IntegerField(blank=True, null=True)
    size =              models.IntegerField(blank=True, null=True)

    raw =               models.TextField(blank=True, null=True)

在 django 中可以实现吗？

基本上就是这个问题Using ORDER BY and GROUP BY together

Answer 1

从 Django 1.11 开始，您可以使用 Subquery feature 来注释数据：

from django.db.models import OuterRef, Subquery

latest = DeviceMessage.objects.filter(device_id=OuterRef('pk')).order_by('-date_entered')

devices = Device.objects.annotate(latest_message_id=Subquery(latest.values('pk')[:1]))
message_ids = [d.latest_message_id for d in devices]
for message in DeviceMessage.objects.filter(pk__in=message_ids).select_related('device'):
    print(device.name, message)

......

Answer 2

“对于每个传感器，选择它的最新消息”

我假设“传感器”指的是Device 模型。在那种情况下（因为您现在已经澄清 BaseModel 是一个抽象基类），它就这么简单（sensor 是您要查询的特定 Device 实例）：

sensor.devicemessage_set.order_by("-date_entered")[0]

如果您想同时查找多个传感器的这些信息，最好使用annotation，例如：

from django.db.models import Max
...
Device.objects.all().annotate(latest_msg=Max("devicemssage_set__date_entered"))

这为每个Device 对象提供了一个名为latest_msg 的（临时）属性，其中包含您想要的信息。