APScheduler（定时任务二配置调度器）

#-*- coding:utf-8 -*-

from pytz import utc

from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.mongodb import MongoDBJobStore
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor


jobstores = {
    ‘mongo‘: MongoDBJobStore(), #调度器名称为mongo的MemoryJobStore（内存任务储存器）
    ‘default‘: SQLAlchemyJobStore(url=‘sqlite:///jobs.sqlite‘)#调度器名称为“default”的SQLAlchemyJobStore
}
executors = {
    ‘default‘: ThreadPoolExecutor(20),#名称为“default ”的ThreadPoolExecutor，最大线程20个
    ‘processpool‘: ProcessPoolExecutor(5)#名称“processpool”的ProcessPoolExecutor，最大进程5个
}
job_defaults = {
    ‘coalesce‘: False, #默认为新任务关闭合并模式（）
    ‘max_instances‘: 3#设置新任务的默认最大实例数为3
}
scheduler = BackgroundScheduler(jobstores=jobstores, executors=executors, job_defaults=job_defaults, timezone=utc)

#-*- coding:utf-8 -*-
from apscheduler.schedulers.background import BackgroundScheduler


# The "apscheduler." prefix is hard coded
scheduler = BackgroundScheduler({
    ‘apscheduler.jobstores.mongo‘: {
         ‘type‘: ‘mongodb‘
    },
    ‘apscheduler.jobstores.default‘: {
        ‘type‘: ‘sqlalchemy‘,
        ‘url‘: ‘sqlite:///jobs.sqlite‘
    },
    ‘apscheduler.executors.default‘: {
        ‘class‘: ‘apscheduler.executors.pool:ThreadPoolExecutor‘,
        ‘max_workers‘: ‘20‘
    },
    ‘apscheduler.executors.processpool‘: {
        ‘type‘: ‘processpool‘,
        ‘max_workers‘: ‘5‘
    },
    ‘apscheduler.job_defaults.coalesce‘: ‘false‘,
    ‘apscheduler.job_defaults.max_instances‘: ‘3‘,
    ‘apscheduler.timezone‘: ‘UTC‘,
})

#-*- coding:utf-8 -*-
from pytz import utc

from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.executors.pool import ProcessPoolExecutor


jobstores = {
    ‘mongo‘: {‘type‘: ‘mongodb‘},
    ‘default‘: SQLAlchemyJobStore(url=‘sqlite:///jobs.sqlite‘)
}
executors = {
    ‘default‘: {‘type‘: ‘threadpool‘, ‘max_workers‘: 20},
    ‘processpool‘: ProcessPoolExecutor(max_workers=5)
}
job_defaults = {
    ‘coalesce‘: False,
    ‘max_instances‘: 3
}
scheduler = BackgroundScheduler()

# ..这里可以添加任务

scheduler.configure(jobstores=jobstores, executors=executors, job_defaults=job_defaults, timezone=utc)