快捷導(dǎo)航

在django-xadmin中APScheduler的啟動(dòng)初始化實(shí)例

更新時(shí)間：2019年11月15日 16:34:43 作者：roystime

今天小編就為大家分享一篇在django-xadmin中APScheduler的啟動(dòng)初始化實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧

環(huán)境: python3.5.x + django1.9.x + xadmin-for-python3

APScheduler做為一個(gè)輕量級(jí)和使用量很多的后臺(tái)任務(wù)計(jì)劃(scheduler)包，可以方便的隨系統(tǒng)啟動(dòng)/關(guān)閉而啟動(dòng)/關(guān)閉，如果整合到django中，啟動(dòng)APScheduler的代碼該寫在哪里好呢，

以下幾個(gè)方式供參考：

1. （推薦）自定義Middleware，非常類似Java中的Filter，缺點(diǎn)是要有URL訪問才會(huì)觸發(fā)啟動(dòng)，如果系統(tǒng)還沒有啟動(dòng)完就訪問了URL會(huì)觸發(fā)__init__多次調(diào)用（多次http同時(shí)請(qǐng)求造成），可以通過threading的lock同步代碼和狀態(tài)限制執(zhí)行一次

class StartupMiddleware(object):
 def __init__(self):
  #啟動(dòng)后臺(tái)任務(wù)APScheduler
  init_scheduler()
 
  from django.core.exceptions import MiddlewareNotUsed
  raise MiddlewareNotUsed #TIP 拋出此異常，則Django將從 middleware 棧中移出該 middleware，請(qǐng)求就不會(huì)經(jīng)過此middleware
 
 def process_request(self, request):
  print("*****enter startup middleware")

scheduler = None
def init_scheduler():
 global scheduler
 lock = threading.Lock() # TIP 多線程同步代碼
 with lock:
  if scheduler and scheduler.running:
   print('*****APScheduler is already started, pid:{}, tid:{}'.format(os.getpid(), threading.current_thread().getName()))
   return scheduler
  executors = {
   'default': ThreadPoolExecutor(5),#線程模式下進(jìn)程池大小
   'processpool': ProcessPoolExecutor(5),#進(jìn)程模式下進(jìn)程池大小
  }
  job_defaults = {
   'coalesce': True, #如果有幾次未執(zhí)行，條件可以時(shí)是否只執(zhí)行一次
   'max_instances': 1, #同一個(gè)job同一時(shí)間最多有幾個(gè)實(shí)例再跑
  }
 
  scheduler = BackgroundScheduler(executors=executors, job_defaults=job_defaults, timezone=timezone(TIME_ZONE))
 
  scheduler.add_job(...)
  scheduler.start()
  return scheduler

2. 應(yīng)用中的settings.py文件，django在開發(fā)環(huán)境默認(rèn)會(huì)啟動(dòng)兩個(gè)python進(jìn)程(對(duì)于開發(fā)環(huán)境還是很實(shí)用的，改代碼后會(huì)自動(dòng)重啟)，放settings.py中的代碼會(huì)被這兩個(gè)python進(jìn)程都調(diào)用一次，當(dāng)然可以通過--reload參數(shù)只啟動(dòng)一個(gè)python進(jìn)程，另外加載settings.py時(shí)部分app還未loaded，限制了應(yīng)用的代碼。

3. 頂層的urls文件，這個(gè)不管你django啟動(dòng)時(shí)是一個(gè)進(jìn)程還是兩個(gè)進(jìn)程，urls文件也只會(huì)被加載一次，但存在的缺陷就是在執(zhí)行makemigrations這樣的命令時(shí)，會(huì)同樣出現(xiàn)app還未loaded的錯(cuò)...

以上這篇在django-xadmin中APScheduler的啟動(dòng)初始化實(shí)例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: