django apscheduler在特

2023-01-31 00:01:12 django apscheduler
 

  如何使程序在特定时间只执行一次,我查了一下。

       celery可以,时间以秒计。

task = mytask.apply_async(args=[10, 20], countdown=60)

  不过,我们存在以天、星期、甚至月的倒计时,感觉celery还是不满足需求。

  最后找到了apscheduler。

from Django.utils import timezone
from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.schedulers.background import BackgroundScheduler
#from apscheduler.jobstores.mongoDB import MonGoDBJobStore
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor

jobstores = {
    'default': SQLAlchemyJobStore(url='sqlite:///jobs.sqlite')
}
executors = {
    'default': ThreadPoolExecutor(20),
    'processpool': ProcessPoolExecutor(5)
}
job_defaults = {
    'coalesce': False,
    'max_instances': 3
}

#异步式的 scheduler = BackgroundScheduler( jobstores=jobstores, executors=executors, job_defaults=job_defaults, timezone=timezone.get_current_timezone())

#阻塞的,适用于scheduler是独立服务的场景。 #scheduler = BlockingScheduler(jobstores=jobstores, executors=executors, job_defaults=job_defaults, timezone=timezone.get_current_timezone()) #scheduler = BlockingScheduler(executors=executors, job_defaults=job_defaults, timezone=timezone.get_current_timezone()) def myjob(): pass try: scheduler.start() # 5s后执行myjob # 传入时间去除毫秒 deadline = datetime.datetime.now().replace(microsecond=0) + datetime.timedelta(seconds=5) scheduler.add_job(myjob, 'date', run_date=deadline) except (KeyboardInterrupt, SystemExit): scheduler.shutdown()

  

相关文章