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

Posted 2023-02-24

【中文标题】如何使用 celery 安排任务在特定时间执行？

【英文标题】：How can I schedule a Task to execute at a specific time using celery?

【发布时间】：2010-12-31 17:21:56

【问题描述】：

我已经查看了PeriodicTask，但这些示例仅涉及使其重复发生。我正在寻找更像cron 的能力，可以说“每周一凌晨 1 点执行此任务”

【参考方案1】：

使用

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

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

【讨论】：

别忘了 eta 是 python 的日期时间，

如果我把它设为PeriodicTask，我只需要第一次安排，对吧？

【参考方案2】：

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

例子：

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

【讨论】：

导入路径已更改为from celery.task import periodic_task和from celery.schedules import crontab

【参考方案3】：

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

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

【参考方案4】：

虽然@asksol 的回答仍然成立，但 API 已更新。对于 celery 4.1.0，我必须导入 crontab 和 periodic_task 如下：

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

【参考方案5】：

你如何阅读这个tutorial，你可以制作一个 PeriodicTask，我想如果你在凌晨 1 点执行了一个任务。周一早上是因为你想运行一个很长的 cpu/mem 操作，记住 celery 使用 ampq 进行入队任务。