|
@@ -1,3 +1,4 @@
|
|
|
|
|
+import re
|
|
|
import time
|
|
import time
|
|
|
from concurrent.futures import ThreadPoolExecutor, wait
|
|
from concurrent.futures import ThreadPoolExecutor, wait
|
|
|
from common.redis import get_pq_id
|
|
from common.redis import get_pq_id
|
|
@@ -9,7 +10,7 @@ max_workers = 10
|
|
|
|
|
|
|
|
def get_video_id():
|
|
def get_video_id():
|
|
|
video_ids = set() # 使用集合去重
|
|
video_ids = set() # 使用集合去重
|
|
|
- for i in range(10):
|
|
|
|
|
|
|
+ for i in range(1):
|
|
|
video_id = get_pq_id()
|
|
video_id = get_pq_id()
|
|
|
if video_id:
|
|
if video_id:
|
|
|
video_ids.add(video_id)
|
|
video_ids.add(video_id)
|
|
@@ -21,9 +22,11 @@ def get_video_id():
|
|
|
|
|
|
|
|
def process_video_cover(video_id):
|
|
def process_video_cover(video_id):
|
|
|
try:
|
|
try:
|
|
|
- CoverMethod.cover_method( int( video_id ) )
|
|
|
|
|
|
|
+ # video_id = int(video_id)
|
|
|
|
|
+ video_id = str(video_id).strip( "b'" ) # 去掉前面的 b 和两边的引号
|
|
|
|
|
+ CoverMethod.cover_method(str(video_id))
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
|
- print( "处理任务时出现异常:", e)
|
|
|
|
|
|
|
+ print( f"视频ID:{video_id}处理任务时出现异常:{e}")
|
|
|
|
|
|
|
|
|
|
|
|
|
def video_cover_task_start():
|
|
def video_cover_task_start():
|
