|
@@ -168,7 +168,7 @@ async function processMessage(msg: Message) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 增加对 eventLog.duration 的校验
|
|
// 增加对 eventLog.duration 的校验
|
|
|
- if (eventData.duration > 10000 || eventData.duration < 0) {
|
|
|
|
|
|
|
+ if (eventData.duration > 100000 || eventData.duration < 0) {
|
|
|
console.warn(`[Ingestor Service] Skipping event with invalid duration: ${eventData.duration}. Event: ${JSON.stringify(eventData)}`);
|
|
console.warn(`[Ingestor Service] Skipping event with invalid duration: ${eventData.duration}. Event: ${JSON.stringify(eventData)}`);
|
|
|
amqpChannel.ack(msg); // Acknowledge and drop invalid messages
|
|
amqpChannel.ack(msg); // Acknowledge and drop invalid messages
|
|
|
return;
|
|
return;
|