Django ORM 在 15 分钟的时间块内获取数据的平均值

Question

我每 30 秒抓取一次数据并将其存储在此模型中。

class Frequency(models.Model):
    """Store the frequency  scraped"""
    timestamp = models.DateTimeField()
    frequency = models.DecimalField(max_digits=5, decimal_places=2)

现在我被分配了一项任务，每天每 15 分钟我必须对结果进行平均并分组为 08:15-08:30、08:30-08:45 .... 23 :45-24:00。

我的想法是使用两个循环。外层会在一天中的几个小时内循环，内层会在 (00, 15, 30, 45) 中循环，然后更改今天的 datetime.now() 并对其进行过滤。

有没有更好的方法或者这样可以吗？？

Answer 1

通过对每个时间跨度进行独立过滤，您将每天进行 24*4 的数据库查询，这对于这样一个简单的操作来说就像很多。要在一个查询中实现它，您可以注释您的 frequencies 查询集并为每个对象设置 closest_quarter_of_hour。然后您可以使用aggregate 获取平均频率，并使用Django values 方法创建一个SQL group by 子句。

from django.db.models import CharField, Case, When, Q, Value, Avg
from django.db.models.functions import ExtractHour, ExtractMinute

today = timezone.now().date()
frequencies = Frequency.objects.filter(timestamp__date=today).annotate(
    hour=ExtractHour("timestamp"),
    minute=ExtractMinute("timestamp"),
).annotate(
    closest_quarter_of_hour=Case(
        When(minute__gte=0, minute__lt=15, then=Value('00-15')),
        When(minute__gte=15, minute__lt=30, then=Value('15-30')),
        When(minute__gte=30, minute__lt=45, then=Value('30-45')),
        When(minute__gte=45, then=Value('45-00')),
        output_field=CharField(),
    )
).aggregate(Avg("frequency")).values("hour", "closeset_quarter_of_hour")

结果：一个 SQL 查询中每 15 分钟时间跨度的平均频率。