先说结论: 在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中继承),因此其使用及初始化不完全相同,有兴趣的可以看下源码。