将芹菜节拍"CELERYBEAT_SCHEDULE"替换为动态源(数据库)



在Celery文档中,设置任务时间表的标准方法被记录为将时间表硬编码到配置文件中。

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

是否有人可以通过从数据库中动态提取时间表或定期从文本文件中重新加载时间表来动态加载时间表,从而避免重新启动芹菜节拍的工作程序?它是否像在文本文件中围绕时间表放置reload()调用一样简单,甚至可能像它自己的计划芹菜任务一样简单?

CELERYBEAT_SCHEDULE只是init/config sugar,对象可以从绑定任务中获得,位置为:

self.app.conf['CELERYBEAT_SCHEDULE']

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

相关内容

  • 没有找到相关文章

最新更新