flask 执行定时任务问题

[Macv1994]

之前用过 APScheduler，可以定时执行任务，但是时间都是需要先设置好，比如使用crontab的方式，这几天了解了一下 celery，发现跟 APScheduler 比较类似，也是需要先设置好时间。

现在有个场景，比如我新建了一个待办事项，时间点为 2020-12-22 11:30 分，我需要在 2020-12-22 11:20 分自动发送邮件通知我，这样的需求怎么实现呢？

我现在想到了两个方法

1. 通过定时任务每 5 分钟查询一次数据库，如果存在需要发送邮件，则发送邮件通知；
2. 通过 celery 异步任务，在创建待办事项的时候，将其加入到异步任务中，通过延时对应的时间，然后发送邮件；

但是感觉这两种方法非常的蠢，有没有大哥给点建议~

[awanabe]

定时任务本质上就是周期扫描数据库
一般都是 1 方案

还有一种方案..你为你这个待办事项提醒单独创建一个 task
每次不用扫描大表, 只要扫描 task 表就可以获取代办任务

[lpts007]

1, 2 都行 2 的话需要注意长延时场景下重复执行的问题

[zachlhb]

celery 的任务可以按时间点执行的，创建不同类型的调度器就行了，clocked 调度器就是在某一个时间点执行

[Macv1994]

@awanabe 如果定时任务变多了，是不是要考虑资源消耗的问题。

[Macv1994]

@zachlhb 我看文档都是需要通过装饰器来先定义任务执行时间吗?有没有链接给我瞅一下，谢谢啦~

[Macv1994]

@lpts007 嗯嗯

[maocat]

celery 延时已经够用了，而且 celery 是支持分布式的，不怕你任务量大

[awanabe]

@Macv1994 是的..要优化 生产者消费者模型..
可以尝试下 定时任务里面调用异步任务咯

[maocat]

@Macv1994 apply_async(args, countdown=1) # countdown 时间可以控制延时时间的，你只用计算好时间差就会把任务挂到任务队列上

[Macv1994]

@awanabe 好的，感谢~

@maocat 嗯嗯，谢谢啦~