调整

app/endpoints/pipeline_endpoint.py

@@ -62,7 +62,7 @@ async def get_messages(request: Request, body: Dict[str, Any]):
         # 为异常附加堆栈跟踪
         e = e.with_traceback(tb)
         # 输出详细的错误信息
-        logger.error(f"处理微信回调消息出错: {body}")
+        logger.error(f"处理微信回调消息出错: {json.dumps(body, separators=(',', ':'),ensure_ascii=False)}")
         logger.error(f"异常类型: {type(e).__name__}")
         logger.error(f"异常信息: {str(e)}")
         logger.error(f"堆栈跟踪: {traceback.format_exc()}")

services/kafka_service.py

@@ -131,7 +131,12 @@ class KafkaService:
                 async for msg in self.consumer:
                     try:
                         # logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)}")
-                        logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)[:300]}")
+                        #logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)[:300]}")
+
+                        json_str = json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)
+                        truncated = json_str if len(json_str) <= 300 else f"{json_str[:297]}..."
+                        logger.info(f"接收到kafka消息: {truncated}")
+                        
                         topic = msg.topic
                         if topic in self.message_handlers:
                             handler = self.message_handlers[topic]