python - 用动态源(数据库)替换 Celery Beat "CELERYBEAT_SCHEDULE"

Question

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

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

有没有人有办法动态加载计划，避免重新启动 celery beat worker 的需要，方法是从数据库中动态提取计划，或者定期从文本文件重新加载计划？是否像在文本文件中围绕调度调用 reload() 一样简单，甚至可能作为其自己的调度 celery 任务？

Answer 1

CELERYBEAT_SCHEDULE 只是 init/config 糖，对象可以从绑定(bind)任务中获得:

self.app.conf['CELERYBEAT_SCHEDULE']

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