|
|
@@ -0,0 +1,22 @@
|
|
|
+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()
|
