Django celery：安排重复任务，但开始日期固定

Question

目前 djcelery 允许我通过 PeriodicTask 模型安排重复任务。例如，一个任务以每分钟的间隔运行，或者由 crontab 指定的间隔，如每个月的第一天中午。然而，我真正想做的是安排一个固定日期的任务，然后每隔一段时间重复一次。例如，在 2016 年 3 月 3 日 2:00 首次运行，然后每隔一小时运行一次。

有没有办法在 django 和 celery 中实现这一点（有或没有 djcelery）？谢谢

Answer 1

正如the docs 中所述，您可以实现自己的自定义调度程序。您应该重写 is_due 方法，该方法决定是否该运行任务。

下面是一个概念验证（我没有检查它是否有错误）。请注意，__reduce__ 方法也被覆盖，因此新参数也被序列化。

import celery.schedules.schedule

class myschedule(celery.schedules.schedule):

    def __init__(self, *args, **kwargs):
        super(myschedule, self).__init__(*args, **kwargs)
        self.start_date = kwargs.get('start_date', None)

    def is_due(self, last_run_at):
        if self.start_date is not None and self.now() < self.start_date:
            return (False, 20)  # try again in 20 seconds
        return super(myschedule, self).is_due(last_run_at)

    def __reduce__(self):
        return self.__class__, (self.run_every, self.relative, self.nowfun, self.start_date)

然后你在配置中使用它：

CELERYBEAT_SCHEDULE = {
    'add-every-30-seconds': {
        'task': 'tasks.add',
        'schedule': myschedule(timedelta(seconds=30), start_date=start_date),
        'args': (16, 16)
    },
}