如何为Celery周期性任务指定结束日期避免超期执行

问题本质 #

crontab表达式本身不支持年份维度的限制，你配置的month_of_year = 10,11、day_of_month = 16-31,1-10规则会匹配每一年的对应日期，这也是后续年份任务仍会被触发的根本原因。

Celery 原生的 crontab 调度器没有提供直接指定周期性任务起止日期的配置项，你可以通过以下两种方案解决问题：

方案1：任务内部加时间校验（推荐，实现成本最低） #

在任务执行入口处增加时间范围判断，不在目标区间内直接跳过业务逻辑即可，无需修改调度配置：

from datetime import datetime, timezone
from celery import shared_task

@shared_task
def your_target_task():
    # 按实际需求调整起止时间，注意时区要和Celery运行时区保持一致
    START_DATETIME = datetime(2021, 10, 16, tzinfo=timezone.utc)
    # 截止到2021-11-10 23:59:59，所以结束时间设为次日0点
    END_DATETIME = datetime(2021, 11, 11, tzinfo=timezone.utc)
    
    now = datetime.now(tz=timezone.utc)
    if not (START_DATETIME <= now < END_DATETIME):
        return
    
    # 以下是实际业务逻辑
    ...

这种方案就算调度器触发了任务调用，也不会执行实际业务，逻辑简单易维护，适合大部分场景。

方案2：从调度层停用任务（避免无效触发） #

如果你用的是 django-celery-beat 做动态任务管理，可以直接给周期性任务配置 expires 字段，传入你需要的结束时间，超过这个时间后任务会被自动停用，不会再被调度：

from django_celery_beat.models import PeriodicTask, CrontabSchedule
from datetime import datetime, timezone

schedule, _ = CrontabSchedule.objects.get_or_create(
    minute='0',
    hour='8', # 按你需要的固定时间调整
    day_of_month='16-31,1-10',
    month_of_year='10,11',
)

PeriodicTask.objects.create(
    crontab=schedule,
    name='你要执行的任务名称',
    task='your_target_task',
    expires=datetime(2021, 11, 11, tzinfo=timezone.utc) # 到期自动停用
)

如果是用原生静态配置的celery beat，也可以手动在结束日期到达后删除对应任务配置，或者自定义调度器增加年份校验逻辑，实现成本高于方案1。

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