Celery Beat - 如何手动调用周期性任务？

Question

在我们的生产环境中，我们有一个 Celerybeat 配置为根据频率执行周期性任务。

我的问题是，有没有办法让我立即启动本应在特定时间运行的任务？

非常感谢任何建议或指导。

我尝试使用Python解释器中的

app.add_periodic_task

添加周期性任务，但它不起作用。

我正在寻找一些帮助来从 Python 解释器或 celery 命令行运行任何特定的计划任务。

Answer 1

我通过以下两个场景实现了这一点。

1. 连接到托管 Celerybeat 的相关 docker 实例容器，并在 Python 解释器中运行以下命令

   从 mymodule.celerybeat 导入清理 cleanup.apply_async()

2. 通过子命令使用 Celery 命令行

   call

   celery -myceleryapp:app 调用 mymodule.celerybeat.cleanup

注意： 这里 myceleryapp 是应用程序名称，cleanup 是定期任务。