减少日志打印

oms/dist/services/ingestor-service.js

@@ -256,7 +256,7 @@ async function processMessage(msg) {
     let eventData;
     try {
         eventData = JSON.parse(msg.content.toString());
-        console.log("[Ingestor Service] Received raw event:", eventData); // Log for debugging, but be cautious with high volume
+        // console.log("[Ingestor Service] Received raw event:", eventData); // Log for debugging, but be cautious with high volume
     }
     catch (parseError) {
         console.error(`[Ingestor Service] Error parsing message content: ${msg.content.toString()}. Error: ${parseError}`);

oms/dist/services/log-service.js

@@ -164,7 +164,7 @@ async function startLogService() {
                 return; // Channel closed or other null message
             try {
                 const eventDataString = msg.content.toString();
-                console.log("[Log Service] Received event:", eventDataString); // 生产环境可以减少日志量
+                // console.log("[Log Service] Received event:", eventDataString); // 生产环境可以减少日志量
                 await retryPushToFile(eventDataString, 3000, 5); // 写入文件，带重试
                 if (amqpChannel) {
                     amqpChannel.ack(msg); // 成功写入文件后确认消息

oms/services/ingestor-service.ts

@@ -234,7 +234,7 @@ async function processMessage(msg: Message) {
   let eventData: any;
   try {
     eventData = JSON.parse(msg.content.toString());
-    console.log("[Ingestor Service] Received raw event:", eventData); // Log for debugging, but be cautious with high volume
+    // console.log("[Ingestor Service] Received raw event:", eventData); // Log for debugging, but be cautious with high volume
   } catch (parseError) {
     console.error(`[Ingestor Service] Error parsing message content: ${msg.content.toString()}. Error: ${parseError}`);
     amqpChannel.reject(msg, false); // Reject malformed message, do not re-queue

oms/services/log-service.ts

@@ -139,7 +139,7 @@ async function startLogService() {
 
         try {
           const eventDataString = msg.content.toString();
-          console.log("[Log Service] Received event:", eventDataString); // 生产环境可以减少日志量
+          // console.log("[Log Service] Received event:", eventDataString); // 生产环境可以减少日志量
 
           await retryPushToFile(eventDataString, 3000, 5); // 写入文件，带重试