调试

analyze_video.py

@@ -19,6 +19,8 @@ lock = asyncio.Lock()
 
 class VideoRequest(BaseModel):
     video_path: str
+    prompt: str
+    mark: str
 
 
 async def get_available_api_key():

job_redis_data.py

@@ -10,7 +10,7 @@ def bot_video_ai_top():
     dt = datetime.datetime.now().strftime('%Y%m%d')
     print(f"开始执行头部{dt}")
     redis_task = 'task:video_ai_top'
-    table_name = 'content_ai_tag_return_top'
+    table_name = 'content_ai_tag_return_top_merge'
     install_video_data(dt, redis_task, table_name)
 
 
@@ -36,5 +36,4 @@ if __name__ == "__main__":
         schedule.run_pending()
         time.sleep(1)  # 每秒钟检查一次
     # bot_video_ai_top()
-    # bot_video_ai_recommend()
-    # bot_video_ai_complex_mode()
+    # bot_video_ai_recommend()