|
@@ -3,6 +3,7 @@
|
|
|
"""
|
|
|
import os
|
|
|
import json
|
|
|
+import time
|
|
|
import uuid
|
|
|
import requests
|
|
|
import urllib.parse
|
|
@@ -106,9 +107,9 @@ def find_videos_in_mysql(trace_id):
|
|
|
os.path.join(dir_path, "{}.json".format(i[0]))
|
|
|
) for i in out_video_list if not "{}.json".format(i[0]) in done_list
|
|
|
]
|
|
|
- with ThreadPoolExecutor(max_workers=10) as pool:
|
|
|
+ with ThreadPoolExecutor(max_workers=2) as pool:
|
|
|
pool.map(ask_kimi_and_save_to_local, process_list)
|
|
|
-
|
|
|
+ time.sleep(5)
|
|
|
return {
|
|
|
"search_videos": "success",
|
|
|
"trace_id": trace_id,
|