|
@@ -29,16 +29,16 @@ def video_task_start():
|
|
|
mark = carry_video.main(json.loads(data), REDIS_NAME, file_path)
|
|
|
print(f"返回用户名: {mark}")
|
|
|
logger.info(f"[+] {NAME}处理一条成功")
|
|
|
- # for filename in os.listdir(CACHE_DIR):
|
|
|
- # # 检查文件名是否包含关键字
|
|
|
- # if uid in filename:
|
|
|
- # file_path = os.path.join(CACHE_DIR, filename)
|
|
|
- # try:
|
|
|
- # # 删除文件
|
|
|
- # os.remove(file_path)
|
|
|
- # logger.info(f"已删除文件: {file_path}")
|
|
|
- # except Exception as e:
|
|
|
- # logger.error(f"删除文件时出错: {file_path}, 错误: {e}")
|
|
|
+ for filename in os.listdir(CACHE_DIR):
|
|
|
+ # 检查文件名是否包含关键字
|
|
|
+ if uid in filename:
|
|
|
+ file_path = os.path.join(CACHE_DIR, filename)
|
|
|
+ try:
|
|
|
+ # 删除文件
|
|
|
+ os.remove(file_path)
|
|
|
+ logger.info(f"已删除文件: {file_path}")
|
|
|
+ except Exception as e:
|
|
|
+ logger.error(f"删除文件时出错: {file_path}, 错误: {e}")
|
|
|
except Exception as e:
|
|
|
data = json.loads(data)
|
|
|
text = (
|