调试

analyze_video.py

@@ -10,8 +10,8 @@ app = FastAPI()
 
 api_keys = [
     {'key': 'AIzaSyAa4H7YzIOiqA0QIDuO6kNErFBoWT-BEtc', 'locked': False},
-    {'key': 'AIzaSyC-IxUvJhbiKWA7uN1RTtVbOjt3pj_-Apc', 'locked': False},
-    {'key': 'AIzaSyB43Pvugb-CMkEXJUSubXEAxKxYflCPPNU', 'locked': False}
+    # {'key': 'AIzaSyC-IxUvJhbiKWA7uN1RTtVbOjt3pj_-Apc', 'locked': False},
+    # {'key': 'AIzaSyB43Pvugb-CMkEXJUSubXEAxKxYflCPPNU', 'locked': False}
 ]
 
 lock = asyncio.Lock()

job_video_processing.py

@@ -10,7 +10,7 @@ def video_ai_task_start():
     with ThreadPoolExecutor( max_workers=max_workers) as executor:
         while True:
             try:
-                redis_task_list = ['task:video_ai'] * 3
+                redis_task_list = ['task:video_ai']
                 # 提交所有任务并等待完成
                 futures = [executor.submit( process_video_ai, redis_task ) for redis_task in redis_task_list]
                 wait( futures )  # 等待所有任务完成