欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

django定时任务库 django_apscheduler

程序员文章站 2022-08-18 08:34:27
django_apscheduler 在做定时任务的时候这个库挺有用的,记得在这个库还不存在的时候,自己也写了一个和这个库功能差不多的django模块。也能用,不过不是很稳定,每次重启wsgi的时候,都要手动启动任务。无意中发现了django_apscheduler 这块第三方库,用了下挺好用的。安装pip install django-apscheduler 将: django_apscheduler 加到 项目setting.py INSTALLED_APPS 中INSTALLED_A...

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