请教一个问题, flask celery 如何实现定时任务动态设定任务的时间间隔

2021-04-26 17:20:44 +08:00
 wunsch0106
1764 次点击
所在节点    Python
9 条回复
jsutfun
2021-04-26 17:25:19 +08:00
设置一个定时器不行么
no1xsyzy
2021-04-26 17:26:58 +08:00
感觉与 flask 和 celery 均无关,而是如何正确处理时相关问题。
“动态设定任务的时间间隔”比较模糊,可能的情况是:

1. 如果上一次任务完成时你必定知道下一次任务应当发生的时间,则在上一次任务的过程中添加下一次任务(以非定时的方式)。
2. 否则,以所有可能的定时任务的最小公约数为间隔执行,添加是否真正执行任务的条件判断。
wunsch0106
2021-04-26 17:30:54 +08:00
@no1xsyzy 抱歉, 没描述清楚。 我先想要定时任务是 2 天 /次, 之后想改为 3 天 /次, 这个几天每次是可修改的,而不是重启 celery
youngce
2021-04-26 17:35:21 +08:00
django 有个 django celery beat 来实现这个需求,flask 没研究过。
wunsch0106
2021-04-26 17:37:18 +08:00
@youngce 确实了解到 django 有这个实现方案, 所以才说明了 flask
37Y37
2021-04-26 17:39:04 +08:00
没记错的话 celery 本身支持的,动态修改,djcelery 这个实现了去数据库读取配置,可以看看源码抄一下
no1xsyzy
2021-04-26 17:41:52 +08:00
wunsch0106
2021-04-26 17:55:28 +08:00
@37Y37 @no1xsyzy 好的,感谢
SjwNo1
2021-04-26 17:56:41 +08:00
估计得重写 beat,先暴露 service,然后调 service.scheduler. update_from_dict 加载动态的 entries

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/773400

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX