energy-data-trans/app.py

# -*- coding: utf-8 -*-
# @Time    : 2024/6/6
# @Author  : 魏志亮
from apscheduler.executors.pool import ThreadPoolExecutor
from flask import Flask
import datetime
from flask_apscheduler import APScheduler


class Config(object):
    JOBS = [
        {
            'id': 'job1',
            'func': 'schedule_service:run_schedule',
            'args': (0, 3),
            'trigger': 'interval',
            'seconds': 60
        }
    ]
    SCHEDULER_EXECUTORS = {'default': ThreadPoolExecutor(6)}
    # 调度器开关开启
    SCHEDULER_API_ENABLED = True
    # 设置容错时间为 2min
    # coalesce积攒得任务跑几次，在时间允许得范围内 True:默认最后一次，False:在时间允许范围内全部提交
    # max_instances 同时允许并发的最大并发量
    # misfire_grace_time 如果重启任务在这个时间范围内，就能继续重启
    SCHEDULER_JOB_DEFAULTS = {'coalesce': False, 'max_instances': 2, 'misfire_grace_time': 60}
    # 配置时区
    SCHEDULER_TIMEZONE = 'Asia/Shanghai'


if __name__ == '__main__':
    app = Flask(__name__)
    app.config.from_object(Config())

    scheduler = APScheduler()
    scheduler.init_app(app)
    scheduler.start()
    app.run()