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()