用动态源（数据库）替换 Celery Beat "CELERYBEAT_SCHEDULE"

Question

在Celery docs 中，设置任务计划的标准方法被记录为将计划硬编码到配置文件中。

但是，它也暗示这可以用自定义后端替换。我看到 Django 有一个动态的、数据库驱动的选项，但我正在使用一个简单的 Flask 应用程序来定义我的任务。

有没有人有办法动态加载计划，避免重新启动 celery beat 工作人员的需要，无论是通过从数据库中动态提取计划还是定期从文本文件中重新加载计划？是否像在文本文件中围绕日程安排调用 reload() 一样简单，甚至可以作为它自己的预定 celery 任务？

Answer 1

CELERYBEAT_SCHEDULE 只是 init/config 糖，对象可从以下绑定任务中获得：

self.app.conf['CELERYBEAT_SCHEDULE']

您可以编写一个周期性任务，从某个后端提取新值。