Django中基于日期自动更新折扣状态的性能优化问询

针对百万级数据量下查询时批量更新折扣状态的性能问题，可从减少实时写操作、异步批量处理、索引优化三个核心方向重构实现：

1. 移除查询时的实时批量更新，改用动态状态计算 #

不再依赖数据库存储的status字段判断当前状态，而是通过模型属性动态计算，彻底避免查询时的写操作：

from django.utils import timezone

class Discount(models.Model):
    start_date = models.DateTimeField()
    expiry_date = models.DateTimeField()
    status = models.CharField(
        max_length=20,
        choices=[('inactive', '未生效'), ('active', '生效中'), ('expired', '已过期')],
        default='inactive'
    )

    @property
    def current_status(self):
        now = timezone.now()
        if self.expiry_date < now:
            return 'expired'
        elif self.start_date > now:
            return 'inactive'
        else:
            return 'active'

业务逻辑中直接使用discount.current_status获取实时状态，无需等待数据库更新。

2. 异步定时任务批量同步状态（可选） #

如果业务需要将状态持久化到数据库（如统计、报表场景），用定时任务替代查询触发的更新，将写操作从查询链路剥离：

from celery import shared_task
from django.utils import timezone
from .models import Discount

@shared_task
def sync_discount_statuses():
    now = timezone.now()
    # 批量激活到起始日期的未生效折扣
    Discount.objects.filter(
        start_date__lte=now,
        status='inactive'
    ).update(status='active')
    
    # 批量标记已过期的生效中折扣
    Discount.objects.filter(
        expiry_date__lt=now,
        status='active'
    ).update(status='expired')
    
    # 恢复延期后的已过期折扣
    Discount.objects.filter(
        expiry_date__gte=now,
        status='expired'
    ).update(status='active')

通过Celery/Django Q等工具设置定时任务（如每5分钟执行一次），将批量更新操作转移到后台异步执行，不影响前端查询性能。

3. 数据库索引优化 #

给过滤条件字段建立联合索引，大幅提升批量更新时的查询效率，减少数据库锁占用时间：

class Discount(models.Model):
    # ... 原有字段 ...

    class Meta:
        indexes = [
            models.Index(fields=['status', 'start_date']),
            models.Index(fields=['status', 'expiry_date']),
        ]

4. 模型保存时的增量更新 #

当折扣的start_date或expiry_date被修改时，仅更新当前折扣的状态，避免全量扫描：

def save(self, *args, **kwargs):
    now = timezone.now()
    need_update_status = False
    # 对比原有数据判断是否需要更新状态
    if self.pk:
        old_discount = Discount.objects.get(pk=self.pk)
        # 起始日期到了且原状态未生效
        if old_discount.start_date > now and self.start_date <= now and self.status == 'inactive':
            self.status = 'active'
            need_update_status = True
        # 过期日期修改后未过期且原状态已过期
        elif old_discount.expiry_date < now and self.expiry_date >= now and self.status == 'expired':
            self.status = 'active'
            need_update_status = True
        # 过期日期提前且原状态生效中
        elif old_discount.expiry_date >= now and self.expiry_date < now and self.status == 'active':
            self.status = 'expired'
            need_update_status = True
    super().save(*args, **kwargs)

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