django定时任务库 django_apscheduler

django_apscheduler 在做定时任务的时候这个库挺有用的，记得在这个库还不存在的时候，自己也写了一个和这个库功能差不多的django模块。也能用，不过不是很稳定，每次重启wsgi的时候，都要手动启动任务。无意中发现了django_apscheduler 这块第三方库，用了下挺好用的。

• 安装

pip install django-apscheduler 

• 将： django_apscheduler 加到 项目setting.py INSTALLED_APPS 中

INSTALLED_APPS = ( 
      ... 
      django_apscheduler, 
)

• 设置后需要同步数据库，执行：

python manage.py migrate

会创建两张表：
django_apscheduler_djangojob
django_apscheduler_djangojobexecution

下面就是写逻辑代码了，需要注意的是，定时器需要写在urls里面，任何模块的urls里面都可以。

# 定时任务库
from apscheduler.schedulers.background import BackgroundScheduler
from django_apscheduler.jobstores import DjangoJobStore, register_events, register_job

# 综合模块
from WanBaoScience import utility_function

# xToolkit
from xToolkit import xdatetime, xstring

# 实例化调度器
scheduler = BackgroundScheduler()
scheduler.add_jobstore(DjangoJobStore(), "default")


# 每天 12,18,21 点执行
@register_job(scheduler, "cron", hour='12,18,21', id='job_one')
def job_one():
    utility_function.enterprise_mailbox("D", "这是每天 12时，18时，21时执行的定时任务，当前时间{}".format(xdatetime.get().format()))


# 每天 0点5分 执行
@register_job(scheduler, "cron", hour=0, minute=5, id='test_two')
def test_two():
    utility_function.enterprise_mailbox("D", "这是每天 0点5分 执行的定时任务，当前时间{}".format(xdatetime.get().format()))


# 每30秒 执行
@register_job(scheduler, "cron", second="0/30", id='test_three')
def test_three():
    pass


register_events(scheduler)
scheduler.start()

• 一些自己踩过的坑：
  1.django_apscheduler + uwsgi 同一个定时任务重复执行 如何解决？

解决这个问题，网上面有三种方法：
1.设置uwsgi 的工作线程为一个
2.用 锁
3.register_job
用 register_job最简单，利用工作id唯一性这个性质就可以解决uwsgi 多进程重复执行的问题。

• 参考资料：

interval/cron触发器详解 常用

interval 触发器
参数 说明
weeks (int) 间隔几周
days (int) 间隔几天
hours (int) 间隔几小时
minutes (int) 间隔几分钟
seconds (int) 间隔多少秒
start_date (datetime 或 str) 开始日期
end_date (datetime 或 str) 结束日期
timezone (datetime.tzinfo 或str) 时区

每隔两分钟执行一次 job_func 方法
scheduler .add_job(job_func, ‘interval’, minutes=2)
在 2017-12-13 14:00:01 ~ 2017-12-13 14:00:10 之间, 每隔两分钟执行一次 job_func 方法
scheduler .add_job(job_func, ‘interval’, minutes=2, start_date=‘2017-12-13 14:00:01’ , end_date=‘2017-12-13 14:00:10’)

cron 触发器:
参数 说明
year (int 或 str) 年，4位数字
month (int 或 str) 月 (范围1-12)
day (int 或 str) 日 (范围1-31
week (int 或 str) 周 (范围1-53)
day_of_week (int 或 str) 周内第几天或者星期几 (范围0-6 或者 mon,tue,wed,thu,fri,sat,sun)
hour (int 或 str) 时 (范围0-23)
minute (int 或 str) 分 (范围0-59)
second (int 或 str) 秒 (范围0-59)
start_date (datetime 或 str) 最早开始日期(包含)
end_date (datetime 或 str) 最晚结束时间(包含)
timezone (datetime.tzinfo 或str) 指定时区

在每年 1-3、7-9 月份中的每个星期一、二中的 00:00, 01:00, 02:00 和 03:00 执行 job_func 任务
scheduler .add_job(job_func, ‘cron’, month=‘1-3,7-9’,day=‘0, tue’, hour=‘0-3’)

本文地址：https://blog.csdn.net/qq_22409661/article/details/107446008