如何使用 celery 安排任务在特定时间执行？

Question

我研究过PeriodicTask，但示例仅涵盖使其重复出现。我正在寻找更像 cron 的能力，可以说“每周一凌晨 1 点执行此任务”

Answer 1

使用

YourTask.apply_async(args=[some, args, here], eta=when)

并在任务结束时，将其重新安排到下一次应该运行的时间。

Answer 2

最近发布的 1.0.3 版本现在支持这一点，感谢 Patrick Altman！

示例：

from celery.task.schedules import crontab
from celery.decorators import periodic_task

@periodic_task(run_every=crontab(hour=7, minute=30, day_of_week="mon"))
def every_monday_morning():
    print("This runs every Monday morning at 7:30a.m.")

有关详细信息，请参阅变更日志：

http://celeryproject.org/docs/changelog.html

Answer 3

我刚刚提交了一个补丁来添加 ScheduledTask 来完成一小部分基于时间的调度与基于周期的调度：

https://github.com/celery/celery/commit/e8835f1052bb45a73f9404005c666f2d2b9a9228

Answer 4

虽然 @asksol 的答案仍然有效，但 api 已更新。对于 celery 4.1.0，我必须导入 crontab 和 periodic_task ，如下所示：

from celery.schedules import crontab
from celery.task import periodic_task