apscheduler + redis：定时任务

通过flask服务，用接口下发定时任务

apscheduler 是python的一个定时任务框架，具体关于apscheduler 的介绍可以百度了解了解

我这就直接描述是怎么用的

首先安装 apscheduler 及 redis 相关依赖模块

# -*- coding: utf-8 -*-
import json
from flask import Flask, jsonify, request
from apscheduler.jobstores.redis import RedisJobStore
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from apscheduler.schedulers.background import BackgroundScheduler

app = Flask(__name__)

def work(time_str):
    print time_str,"to do ..........."
    with open("job.txt", "a") as f:
        f.write(time_str + "n")
    return 1

def apscheduler_init():
    # redis的连接串
    REDIS = {
        'host': '127.0.0.1',
        'port': '6379',
        'db': 15
    }

    # 设置任务的存储位置为redis
    jobstores = {
        'redis': RedisJobStore(**REDIS)
    }

    # 设置定时任务运行的线程和进程，可选配置
    executors = {
        'default': ThreadPoolExecutor(10),  # 默认线程数
        'processpool': ProcessPoolExecutor(4)  # 默认进程
    }

    # 实例定时任务对象，用于定时任务的添加，修改，删除等等操作
    scheduler = BackgroundScheduler(jobstores=jobstores, executors=executors)
    return scheduler

scheduler = apscheduler_init()

@app.route("/add_job",methods=["GET"])
def add_job():
    date = json.loads(request.data).get("date")
    # 根据接口参数添加一个在预定时间运行一次就结束的定时任务
    scheduler.add_job(
        work, # 执行任务的函数
        'date', # 任务运行类型 date 为一次性任务，其它几种类型可百度了解
        jobstore='redis',# 任务存储的对象
        run_date=str(date), # 任务运行的时间
        id="1", # 设置一个任务 id
        args=[date] # 函数参数
    )
    return jsonify({"msg":"ok"})

通过接口请求url下发定时任务后，可在redis中查看对应任务