测试环境

routes/generateSourceRoute.py

@@ -0,0 +1,4 @@
+"""
+@author: luojunhui
+生成sourceId
+"""

touliu_schedule_app.py

@@ -7,6 +7,7 @@ import asyncio
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from apscheduler.triggers.cron import CronTrigger
 
+
 from dailyTasks import updateFromOdps
 
 
@@ -20,28 +21,24 @@ async def asyncUpdatePQVideosTask():
     await ufo.insertIntoDB(data_list=video_list)
 
 
-def asyncScheduleJob():
-    """
-    更新代码
-    :return:
-    """
-    scheduler = AsyncIOScheduler()
-    # 设置一个cron触发器，hour是整时，minute是分钟
-    trigger = CronTrigger(hour=10, minute=26)
-    scheduler.add_job(asyncUpdatePQVideosTask, trigger)
-    scheduler.start()
-
-
 if __name__ == '__main__':
     # 直接执行
-    asyncio.run(asyncUpdatePQVideosTask())
+    # asyncio.run(asyncUpdatePQVideosTask())
+
     # 定时执行
-    # loop = asyncio.get_event_loop()
-    # asyncScheduleJob()
-    # try:
-    #     loop.run_forever()  # 保持事件循环运行
-    # except (KeyboardInterrupt, SystemExit):
-    #     pass
+    scheduler = AsyncIOScheduler()
+
+    # 早上9点10分执行更新视频任务
+    trigger_update_videos = CronTrigger(hour=9, minute=10)
+    scheduler.add_job(asyncUpdatePQVideosTask, trigger_update_videos)
+
+    scheduler.start()
+
+    loop = asyncio.get_event_loop()
+    try:
+        loop.run_forever()  # 保持事件循环运行
+    except (KeyboardInterrupt, SystemExit):
+        pass