定时任务框架APScheduler

APScheduler基于Quartz的一个Python定时任务框架，实现了Quartz的所有功能，使用起来十分方便。提供了基于日期、固定时间间隔以及crontab类型的任务，并且可以持久化任务。基于这些功能，我们可以很方便的实现一个python定时任务系统。

1、利用pip进行安装

pip install apscheduler

2、 apscheduler有5个动作：

1）添加作业

通过add_job()来添加作业，另外还有一种方式是通过scheduled_job()修饰器来修饰函数

import time

from apscheduler.schedulers.blocking importBlockingScheduler

sched =BlockingScheduler()

@sched.scheduled_job('interval', seconds=5)

def my_job():  

print(time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

sched.start()

2）移除作业

job =scheduler.add_job(myfunc, 'interval', minutes=2)

job.remove()

#如果有多个任务序列的话可以给每个任务设置ID号，可以根据ID号选择清除对象，且remove放到start前才有效

sched.add_job(myfunc, 'interval', minutes=2, id='my_job_id')

sched.remove_job('my_job_id')

3）暂停和恢复作业

apsched.job.Job.pause();//暂停

apsched.schedulers.base.BaseScheduler.pause_job();

apsched.job.Job.resume();//恢复

apsched.schedulers.base.BaseScheduler.resume_job();

4）获得job列表

获得调度作业的列表，可以使用get_jobs()来完成，它会返回所有的job实例。或者使用print_jobs()来输出所有格式化的作业列表。也可以利用get_job(任务ID)获取指定任务的作业列表

job =sched.add_job(my_job, 'interval', seconds=2,id='123')

print(sched.get_job(job_id='123'))

print(sched.get_jobs())

5）关闭调度器

默认情况下调度器会等待所有正在运行的作业完成后，关闭所有的调度器和作业存储。如果你不想等待，可以将wait选项设置为False。

sched.shutdown()

sched.shutdown(wait=False)

3、add_job的第二个参数trigger详解

它管理着作业的调度方式。它可以为date, interval或者cron。对于不同的trigger，对应的参数也相同。

1）cron定时调度（某一定时时刻执行），例子：

#表示2017年3月22日17时19分07秒执行该程序

sched.add_job(my_job, 'cron', year=2017,month =03,day =22,hour =17,minute =19,second =07)

#表示任务在6,7,8,11,12月份的第三个星期五的00:00,01:00,02:00,03:00 执行该程序

sched.add_job(my_job, 'cron', month='6-8,11-12', day='3rd fri', hour='0-3')

#表示从星期一到星期五5:30（AM）直到2014-05-30 00:00:00

sched.add_job(my_job(), 'cron', day_of_week='mon-fri', hour=5, minute=30,end_date='2014-05-30')

#表示每5秒执行该程序一次，相当于interval 间隔调度中seconds = 5

sched.add_job(my_job, 'cron',second ='*/5')

2）interval 间隔调度（每隔多久执行）

#表示每隔3天17时19分07秒执行一次任务

sched.add_job(my_job, 'interval',days  =03,hours =17,minutes =19,seconds =07)

3） date 定时调度（作业只会执行一次）

# The job will be executed on November 6th, 2009

sched.add_job(my_job, 'date', run_date=date(2009, 11, 6), args=['text'])

# The job will be executed on November 6th, 2009 at 16:30:05

sched.add_job(my_job, 'date', run_date=datetime(2009, 11, 6, 16, 30, 5), args=['text'])

4、apscheduler如何传递参数给job

import tornadofrom apscheduler.schedulers.tornado import TornadoScheduler

sched = TornadoScheduler()

def job1(a, b, c):    
  print "job1:", a,b,c

def
job2(a, b, c):    
  print "job2:", a,b,c

sched.add_job(job1, 'interval', seconds=1, args=["a", "b", "c"])

sched.add_job(job2, 'interval', seconds=1, kwargs={"a": "a", "b": "b", "c": "c"})

sched.start()

tornado.ioloop.IOLoop.instance().start()