change

utils/piaoquan.py

@@ -1,4 +1,3 @@
-
 import requests
 from urllib.parse import urlencode
 import json
@@ -102,8 +101,9 @@ class PQ:
                 code = response['code']
                 if code == 0:
                     data = response['data']
-                    video_path = data["videoPath"]
-                    video_title = data["title"]
+                    # 优先使用转码后的视频路径
+                    video_path = data.get("transedVideoPath") or data.get("videoPath")
+                    video_title = data.get("title", "")
 
                     return video_title, video_path
             return None

workers/video_insight_select_work.py

@@ -31,7 +31,7 @@ def requirement_insight():
         logger.error(f"[R] 写入Redis写入失败，失败信息{e}")
 
 def schedule_tasks():
-    schedule.every().day.at("16:00").do(requirement_insight)
+    schedule.every().day.at("1:00").do(requirement_insight)
 
 
 if __name__ == "__main__":

workers/video_insight_trigger_work.py

@@ -169,7 +169,7 @@ async def run():
     scheduler = AsyncIOScheduler()
     try:
         logger.info(f"[处理 - trigger] 开始启动")
-        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=10))  # 每5分钟启动一次
+        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=7))  # 每5分钟启动一次
         scheduler.start()
         await asyncio.Event().wait()
     except KeyboardInterrupt: