Flask_APScheduler的簡單使用

首先安裝： pip install flask_apscheduler

 

from apscheduler.events import EVENT_JOB_EXECUTED, EVENT_JOB_ERROR
from flask import Flask
from flask_apscheduler import APScheduler
import datetime

app = Flask(__name__)


@app.route('/index')
def index():
    print('index')
    return 'index'


def aps_timer():
    """
    注意： 這兒不要try, 否則APScheduler 監控不到job的異常
    :return:
    """
    # num = 1 / 0
    print(datetime.datetime.now())


def aps_lister(event):
    if event.exception:
        print('%s:發生異常[%s]，可以郵件通知運維人員' % (event.job_id, event.exception))
    else:
        print('%s:運行正常' % event.job_id)


if __name__ == '__main__':
    scheduler = APScheduler()
    scheduler.init_app(app)
    scheduler.add_job(func=aps_timer, trigger='interval', seconds=10, id='aps_timer')
    scheduler.add_listener(aps_lister, EVENT_JOB_EXECUTED | EVENT_JOB_ERROR)
    scheduler.start()
    app.run()

 

這樣即可