环境:

  • celery 4.3
  • flask
  • python 3.7
  • linux

 

需求:

  动态添加定时任务,且方便维护。

 

解决思路:

  参考django-celery 或是celery源码,将定时任务配置放置到数据库中,从而维护数据达到动态定时任务到效果。

  定时任务对应的是beat, beat将产生task给worker.beat的scheduler是可以定制的,通过BEAT_SCHEDULER将其传入。

 

定制scheduler:

  查看Scheduler源码可知

  

def get_schedule(self):
        return self.data

def set_schedule(self, schedule):
        self.data = schedule

  

get_schedule可以写成从数据库中获取,set_schedule写成将任务写入数据库中

 需要注意的是last_run_at,beat 将通过这个值来确定任务下次运行时间。

 

总成品:

celery 动态定时任务探索

 

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-07-12
  • 2022-12-23
  • 2021-09-01
  • 2021-07-02
  • 2021-08-09
猜你喜欢
  • 2021-08-27
  • 2022-01-20
  • 2021-12-27
  • 2021-07-02
  • 2022-12-23
相关资源
相似解决方案