| 12345678910111213141516171819202122 |
- import time
- from apscheduler.schedulers.background import BackgroundScheduler
- from django_apscheduler.jobstores import DjangoJobStore
- from Ansjer.config import LOGGER
- from django_apscheduler.models import DjangoJob
- def auto_hello():
- now_time = time.time()
- print('hello world:[{}]'.format(now_time))
- def add_job(task_id, hour, minute):
- scheduler = BackgroundScheduler()
- scheduler.add_jobstore(DjangoJobStore(), 'default')
- scheduler.add_job(auto_hello, 'cron', day='*', hour=hour, minute=minute, replace_existing=True, id=task_id,
- max_instances=1, coalesce=True)
- scheduler.start()
- def del_job(task_id):
- DjangoJob.objects.filter(id=task_id).delete()
|
