当前日期作为使用 celerybeatC 计划的任务中的参数

Question

我正在尝试设置一个在运行时传递日期的 crontab 任务，如下所示：

 beat_schedule = {
    'mytask': { 
        'task': 'mytask',
        'schedule': crontab(day_of_week='mon,tue,wed,thu,fri,sat', hour=3, minute=0),
        'args': (date.today().strftime('%Y%m%d')),
    },
}

我怎样才能做到这一点？

谢谢

Answer 1

我认为 Celery beat 做不到这一点。首先想到的解决方法是编写一个小的 Celery 任务，将 date.today().strftime('%Y%m%d') 传递给 mytask。然后将该任务添加到 Celery beat 配置而不是 mytask.

当前日期作为使用 celerybeatC 计划的任务中的参数

current date as argument in a task scheduled with celerybeatC

python

celery

celerybeat