django-apscheduler定時任務

安裝apscheduler 模塊

pip install apscheduler 
pip install django-apscheduler 

將 django-apscheduler 加到項目中settings的INSTALLED_APPS中

 INSTALLED_APPS = [

   ....

'django_apscheduler',

]

執行：

# python manage.py migrate
沒有其餘表結構沒必要運行  python   manage.py      makemigrations

會建立兩張表：django_apscheduler_djangojob/django_apscheduler_djangojobexecution
經過進入後臺管理能方便管理定時任務。

在Django工程目錄下的urls.py文件中，或者說主urls.py中引入以下內容

from apscheduler.schedulers.background import BackgroundScheduler
from django_apscheduler.jobstores import DjangoJobStore, register_events, register_job

scheduler = BackgroundScheduler()
scheduler.add_jobstore(DjangoJobStore(), "default")


# 時間間隔3秒鐘打印一次當前的時間
@register_job(scheduler, "interval", seconds=3, id='test_job')
def test_job():
    print("我是apscheduler任務")
# per-execution monitoring, call register_events on your scheduler
register_events(scheduler)
scheduler.start()
print("Scheduler started!")

 

 

 運行結果以下：

APScheduler中兩種調度器的區別及使用過程當中要注意的問題

APScheduler中有不少種不一樣類型的調度器，BlockingScheduler與BackgroundScheduler是其中最經常使用的兩種調度器。區別主要在於BlockingScheduler會阻塞主線程的運行，而BackgroundScheduler不會阻塞。因此，咱們在不一樣的狀況下，選擇不一樣的調度器：

• BlockingScheduler: 調用start函數後會阻塞當前線程。當調度器是你應用中惟一要運行的東西時（如上例）使用。
• BackgroundScheduler: 調用start後主線程不會阻塞。當你不運行任何其餘框架時使用，並但願調度器在你應用的後臺執行。

BlockingScheduler的真實例子

from apscheduler.schedulers.blocking import BlockingScheduler
import time

def job():
    print('job 3s')


if __name__=='__main__':

    sched = BlockingScheduler(timezone='MST')
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)

運行結果：
job 3s
job 3s
job 3s
job 3s

可見，BlockingScheduler調用start函數後會阻塞當前線程，致使主程序中while循環不會被執行到。

BackgroundScheduler的真實例子

from apscheduler.schedulers.background import BackgroundScheduler
import time

def job():
    print('job 3s')


if __name__=='__main__':

    sched = BackgroundScheduler(timezone='MST')
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)

運行結果：
main 1s
main 1s
main 1s
job 3s
main 1s
main 1s
main 1s
job 3s

可見，BackgroundScheduler調用start函數後並不會阻塞當前線程，因此能夠繼續執行主程序中while循環的邏輯。

經過這個輸出，咱們也能夠發現，調用start函數後，job()並不會當即開始執行。而是等待3s後，纔會被調度執行。

如何讓job在start()後就開始運行

如何才能讓調度器調用start函數後，job()就當即開始執行呢？

其實APScheduler並無提供很好的方法來解決這個問題，但有一種最簡單的方式，就是在調度器start以前，就運行一次job()，以下

from apscheduler.schedulers.background import BackgroundScheduler
import time

def job():
    print('job 3s')


if __name__=='__main__':
    job()
    sched = BackgroundScheduler(timezone='MST')
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)


運行結果：
job 3s
main 1s
main 1s
main 1s
job 3s
main 1s
main 1s
main 1s

這樣雖然沒有絕對作到「讓job在start()後就開始運行」，但也能作到「不等待調度，而是剛開始就運行job」。　　

若是job執行時間過長會怎麼樣

若是執行job()的時間須要5s，但調度器配置爲每隔3s就調用一下job()，會發生什麼狀況呢？咱們寫了以下例子：

from apscheduler.schedulers.background import BackgroundScheduler
import time

def job():
    print('job 3s')
    time.sleep(5)

if __name__=='__main__':

    sched = BackgroundScheduler(timezone='MST')
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)

運行結果：
main 1s
main 1s
main 1s
job 3s
main 1s
main 1s
main 1s
Execution of job "job (trigger: interval[0:00:03], next run at: 2018-05-07 02:44:29 MST)" skipped: maximum number of running instances reached (1)
main 1s
main 1s
main 1s
job 3s
main 1s

可見，3s時間到達後，並不會「從新啓動一個job線程」，而是會跳過該次調度，等到下一個週期（再等待3s），又從新調度job()。

爲了能讓多個job()同時運行，咱們也能夠配置調度器的參數max_instances，以下例，咱們容許2個job()同時運行

from apscheduler.schedulers.background import BackgroundScheduler
import time

def job():
    print('job 3s')
    time.sleep(5)

if __name__=='__main__':
    job_defaults = { 'max_instances': 2 }
    sched = BackgroundScheduler(timezone='MST', job_defaults=job_defaults)
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)

運行結果：
main 1s
main 1s
main 1s
job 3s
main 1s
main 1s
main 1s
job 3s
main 1s
main 1s
main 1s
job 3s

每一個job是怎麼被調度的

經過上面的例子，咱們發現，調度器是定時調度job()函數，來實現調度的。

那job()函數會被以進程的方式調度運行，仍是以線程來運行呢？

爲了弄清這個問題，咱們寫了以下程序：

from apscheduler.schedulers.background import BackgroundScheduler
import time,os,threading

def job():
    print('job thread_id-{0}, process_id-{1}'.format(threading.get_ident(), os.getpid()))
    time.sleep(50)

if __name__=='__main__':
    job_defaults = { 'max_instances': 20 }
    sched = BackgroundScheduler(timezone='MST', job_defaults=job_defaults)
    sched.add_job(job, 'interval', id='3_second_job', seconds=3)
    sched.start()

    while(True):
        print('main 1s')
        time.sleep(1)

運行結果：
main 1s
main 1s
main 1s
job thread_id-10644, process_id-8872
main 1s
main 1s
main 1s
job thread_id-3024, process_id-8872
main 1s
main 1s
main 1s
job thread_id-6728, process_id-8872
main 1s
main 1s
main 1s
job thread_id-11716, process_id-8872

可見，每一個job()的進程ID都相同，但線程ID不一樣。因此，job()最終是以線程的方式被調度執行。　　

BlockingScheduler定時任務及其餘方式的實現　

#BlockingScheduler定時任務
from apscheduler.schedulers.blocking import BlockingScheduler
from datetime import datetime
首先看看週一到週五定時執行任務
# 輸出時間
def job():
  print(datetime.now().strtime("%Y-%m-%d %H:%M:%S"))
# BlockingScheduler
scheduler = BlockingScheduler()
scheduler.add_job(job, "cron"， day_of_week="1-5", hour=6, minute=30)
schduler.start()
 
 
scheduler.add_job(job, 'cron', hour=1, minute=5)
hour =19 , minute =23  這裏表示天天的19：23 分執行任務
hour ='19', minute ='23'  這裏能夠填寫數字，也能夠填寫字符串
hour ='19-21', minute= '23'  表示 19:2三、 20:2三、 21:23 各執行一次任務
 
#每300秒執行一次
scheduler .add_job(job, 'interval', seconds=300)
 
#在1月,3月,5月,7-9月，天天的下午2點，每一分鐘執行一次任務
scheduler .add_job(func=job, trigger='cron', month='1,3,5,7-9', day='*', hour='14', minute='*')
 
# 當前任務會在 六、七、八、十一、12 月的第三個週五的 0、一、二、3 點執行
scheduler .add_job(job, 'cron', month='6-8,11-12', day='3rd fri', hour='0-3')
 
#從開始時間到結束時間，每隔倆小時運行一次
scheduler .add_job(job, 'interval', hours=2, start_date='2018-01-10 09:30:00', end_date='2018-06-15 11:00:00')
 
#自制定時器
 from datetime import datetime
 import time
 # 每n秒執行一次
 def timer(n):
   while True:
     print(datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
     time.sleep(n)
 
timer(5)

BackgroundScheduler定時任務及其餘方式的實現　

 

啓動異步定時任務
 import time
 from apscheduler.schedulers.background import BackgroundScheduler
 from django_apscheduler.jobstores import DjangoJobStore, register_events, register_job
 try: 
    # 實例化調度器
    scheduler = BackgroundScheduler()
    # 調度器使用DjangoJobStore()
    scheduler.add_jobstore(DjangoJobStore(), "default")
    # 'cron'方式循環，週一到週五，天天9:30:10執行,id爲工做ID做爲標記
    # ('scheduler',"interval", seconds=1) #用interval方式循環，每一秒執行一次
    @register_job(scheduler, 'cron', day_of_week='mon-fri', hour='9', minute='30', second='10',id='task_time')
    def test_job():
      t_now = time.localtime()
      print(t_now)
  
   # 監控任務
   register_events(scheduler)
   # 調度器開始
   scheduler.start()
except Exception as e:
  print(e)
  # 報錯則調度器中止執行
  scheduler.shutdown()

 

　　

參考連接https://blog.csdn.net/ybdesire/article/details/82228840