luojunhui 5 months ago
parent
commit
ea2af53a32
1 changed files with 17 additions and 0 deletions
  1. 17 0
      tasks/history_task.py

+ 17 - 0
tasks/history_task.py

@@ -170,6 +170,15 @@ class historyContentIdTask(object):
                 )
                 if fission_resort_list:
                     total_video_list = fission_resort_list + download_videos
+                    logging(
+                        code=1106,
+                        info="查找裂变信息成功",
+                        trace_id=trace_id,
+                        data={
+                            "ori_list": download_videos[:3],
+                            "fission_list": fission_resort_list
+                        }
+                    )
                     # for index, video in enumerate(download_videos[:3]):
                     #     # 使用fission_list中的oss路径替换, 若替换失败则使用原来的视频
                     #     try:
@@ -181,6 +190,14 @@ class historyContentIdTask(object):
                     video_list = total_video_list[:3]
                 else:
                     # 未找到裂变信息,采用原来的顺序
+                    logging(
+                        code=1107,
+                        info="查找裂变信息失败",
+                        trace_id=trace_id,
+                        data={
+                            "ori_list": download_videos[:3]
+                        }
+                    )
                     video_list = download_videos[:3]
             case _:
                 print("未传流量池信息")