feat: 跳过m3u8 视频

workers/video_insight_trigger_work.py

@@ -42,18 +42,21 @@ class ConsumptionRecommend(object):
             if not count or count[0][0] == 0:
                 logger.info(f"[处理 - trigger] 视频ID {video_id} 可用")
                 # 这里可以继续处理 video_id
+                video_title, video_path, transed_video_path = PQ.get_pq_oss(video_id)
+                # 优先使用transed_video_path，没有则使用video_path
+                if not transed_video_path:
+                    transed_video_path = video_path
+                if not video_path:
+                    return
+                # 如果transed_video_path以m3u8结尾，则取消这次任务，读取下一个
+                if transed_video_path.endswith('.m3u8'):
+                    logger.info(f"[处理 - trigger] 视频ID {video_id} 为m3u8格式，跳过")
+                    continue
                 break
             else:
                 logger.info(f"[处理 - trigger] 视频ID {video_id} 重复过滤，继续获取下一个任务")
 
-        logger.info(f"[处理 - trigger] 开始获取原视频OSS地址")
-        video_title, video_path, transed_video_path = PQ.get_pq_oss(video_id)
-        # 优先使用transed_video_path，没有则使用video_path
-        if not transed_video_path:
-            transed_video_path = video_path
-        if not video_path:
-            return
-        logger.info(f"[处理 - trigger] 获取原视频OSS地址，视频链接:{transed_video_path}")
+        logger.info(f"[处理 - trigger] 开始获取原视频OSS地址，视频链接:{transed_video_path}")
         video_url = f"http://rescdn.yishihui.com/{transed_video_path}"
         logger.info(f"[处理 - trigger] 开始分析视频")
         api_key = os.getenv("VIDEO_INSIGHT_GEMINI_API_KEY")