在django框架中用uwsgi跑定時任務


怎么在用Django框架的Python程序中跑定時任務呢?用系統里面的crontab來跑的話任務成功或失敗以及任務返回的結果都無法發送給程序,造成定時任務與程序的割裂,不方便進行控制。

想要實現定時任務,必須要有一個daemon進程一直在后台運行,如果Python程序是用uwsgi啟動的,使用uwsgi就可以實現

uwsgi實現定時任務的Python接口詳細請參考官方文檔

把下面的代碼加入uwsgi的入口程序中,通常可以寫到Django程序的wsgi.py里面:

import uwsgi
from django.core.wsgi import get_wsgi_application

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "project.settings")

application = get_wsgi_application()

# 將具體的cron job分到另一個文件中寫,便於維護
import TimerTasks as tt

for job_id, job in enumerate(tt.jobs):
    uwsgi.register_signal(job_id, "", job['name'])
    if len(job['time']) == 1:
        uwsgi.add_timer(job_id, job['time'][0])
    else:
        uwsgi.add_cron(job_id, job['time'][0], job['time'][1], job['time'][2], job['time'][3], job['time'][4])

以下是TimerTasks .py,增加、刪除定時任務只需要修改這個Python腳本:

import time

def cron_print_time(signum):
    ISOTIMEFORMAT='%Y-%m-%d %X'
    print time.strftime(ISOTIMEFORMAT, time.localtime())

def cron_print_hello(signum):
    print "hello"

jobs = [ { "name" : cron_print_time,
           "time": [0, 17, -1, -1, 1], #minute, hour, day, month, weekday, "-1" means "all",此例為每個周一的17:00
          },     
         { "name" : cron_print_hello,
           "time": [2],  #每隔2秒
          },    
]


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM