flask-apscheduler 使用sqlite3进行持久化存储的配置(非纯apscheduler)解决flask-apscheduler无法持久化存储job的问题

佴阳曦
2023-12-01

先说结论: 在flask 中配置 "SCHEDULER_JOBSTORES" 变量 例子如下:

SCHEDULER_JOBSTORES = {
        'default': SQLAlchemyJobStore(url='sqlite:///jobstores.db')
    }

在apscheduler 创建之前 flask 的app 实例载入配置即可

DEBUG   过程简述~

1. 纯apscheduler 在使用持久化时候可以使用多种方法 举一个例子:

jobstores = {
    'default': SQLAlchemyJobStore(url='sqlite:///jobstores.db')
}

executes = {
    'default': ThreadPoolExecutor(10)
}
scheduler = BackgroundScheduler(jobstores=jobstores, executes=executes)

2. 在创建flask的apscheduler实例时候可以指定一个scheduler

tempScheduler = BackgroundScheduler()
scheduler = APScheduler(scheduler=tempScheduler)

3. 由此推断可以将 (1)1 里面的sheduler 赋值到 (2)中就可以正常运行时错误的

4. 遇到的问题 scheduler 可以正常使用,但是已经添加的JOB第二次启动时候无法正确载入,对应的sqlite路径没有创建对应的.db文件,简单的说你添加的job没有存进你想要的sqlite里

5.ctrl+左键(pycharm中)查看Apscheduler类的源码第 300行左右:

#ctrl+左键点击 APScheduler
scheduler = APScheduler(scheduler=tempScheduler)
    # 源码第 300行左右有写: 这个jobstore的配置是由 flask 的配置文件导入的
    def _load_config(self):
        """
        Load the configuration from the Flask configuration.
        """
        options = dict()

        job_stores = self.app.config.get('SCHEDULER_JOBSTORES')
        if job_stores:
            options['jobstores'] = job_stores

        executors = self.app.config.get('SCHEDULER_EXECUTORS')
        if executors:
            options['executors'] = executors

        job_defaults = self.app.config.get('SCHEDULER_JOB_DEFAULTS')
        if job_defaults:
            options['job_defaults'] = job_defaults

        timezone = self.app.config.get('SCHEDULER_TIMEZONE')
        if timezone:
            options['timezone'] = timezone

        self._scheduler.configure(**options)
    ......

这里可以看到,相关的配置是借由flask的app实例传入的,并不是用scheduler中提取的。

6. 配置的注意事项: 使用 app.config.from_object 好用

本人使用 app.config["SCHEDULER_JOBSTORES"] = {....} 这个模式并不起作用,可能是因为

本身代码就有载入配置的语句app.config.from_object(config),可能是这个配置有排他性(有这个其他方式不起作用?)这里大家可能需要注意下。

PS: 在步骤3 中提到的 BackgroundScheduler() 可以正常使用,却不能使用jobstore=xx 的模式配置jobstore的原因是flask-apscheduler 中的APScheduler 并不完全是普通的Scheduler(没有从BaseScheduler中继承),因此其使用及初始化不完全相同,有兴趣的可以看下源码。

 类似资料: