调试

common/aliyun_log.py

@@ -45,35 +45,35 @@ class AliyunLogger:
         project = "crawler-log-prod"
         logstore = "rewriting-log"
         endpoint = "cn-hangzhou.log.aliyuncs.com"
-        if data:
-            data = dict(item.split(":", 1) for item in data.split(",,"))
-
-        contents = [
-            ("principal", principal),
-            ("channel", channel),
-            ("channel_user", str(channel_user) if channel_user is not None else ""),
-            ("channel_video_id", str(channel_video_id) if channel_video_id is not None else ""),
-            ("message", str(message) if message is not None else ""),
-            ("code", str(code) if code is not None else ""),
-            ("data", json.dumps(data, ensure_ascii=False) if data else ""),
-            ("pq_video_id", pq_video_id if pq_video_id else "")
-        ]
-        # 创建 LogClient 实例
-        client = LogClient(endpoint, accessKeyId, accessKey)
-        log_group = []
-        log_item = LogItem()
-        log_item.set_contents(contents)
-        log_group.append(log_item)
-        # 写入日志
-        request = PutLogsRequest(
-            project=project,
-            logstore=logstore,
-            topic="",
-            source="",
-            logitems=log_group,
-            compress=False,
-        )
         try:
+            if data:
+                data = dict(item.split(":", 1) for item in data.split(",,"))
+            contents = [
+                ("principal", principal),
+                ("channel", channel),
+                ("channel_user", str(channel_user) if channel_user is not None else ""),
+                ("channel_video_id", str(channel_video_id) if channel_video_id is not None else ""),
+                ("message", str(message) if message is not None else ""),
+                ("code", str(code) if code is not None else ""),
+                ("data", json.dumps(data, ensure_ascii=False) if data else ""),
+                ("pq_video_id", pq_video_id if pq_video_id else "")
+            ]
+            # 创建 LogClient 实例
+            client = LogClient(endpoint, accessKeyId, accessKey)
+            log_group = []
+            log_item = LogItem()
+            log_item.set_contents(contents)
+            log_group.append(log_item)
+            # 写入日志
+            request = PutLogsRequest(
+                project=project,
+                logstore=logstore,
+                topic="",
+                source="",
+                logitems=log_group,
+                compress=False,
+            )
+
             client.put_logs(request)
         except Exception as e:
             Common.logger('aliyun').error(f"写入日志失败: {e}")

video_rewriting/video_processor.py

@@ -266,7 +266,10 @@ class VideoProcessor:
                                 voice
                             ]
                         ]
+                    print(f"开始写入{channel_id, name, url, v_id, log_data, str(code)}")
                     AliyunLogger.logging(channel_id, name, url, v_id, "视频改造成功", "1000", log_data, str(code))
+                    print(f"写入成功{channel_id, name, url, v_id, log_data, str(code)}")
+
                     text = (
                         f"**通知类型**: 视频改造成功\n"
                         f"**站内视频链接**: {pq_url}\n"