From 3cd43300892d9e2e8d9b9f1fd829c0eede984767 Mon Sep 17 00:00:00 2001 From: akvlad Date: Wed, 29 Jan 2025 13:36:45 +0200 Subject: [PATCH 1/2] fix --- lib/handlers/otlp_log_push.js | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lib/handlers/otlp_log_push.js b/lib/handlers/otlp_log_push.js index 80419200..9e45976e 100644 --- a/lib/handlers/otlp_log_push.js +++ b/lib/handlers/otlp_log_push.js @@ -30,7 +30,12 @@ async function handle (req, res) { } const labels = stringify(logAttrs) const fingerprint = fingerPrint(labels) - const ts = BigInt(logRecord.timeUnixNano) + const timestamp = logRecord.timeUnixNano + ? BigInt(logRecord.timeUnixNano) + : logRecord.observedTimeUnixNano + ? BigInt(logRecord.observedTimeUnixNano) + : BigInt(Date.now()) * BigInt(1000000) + const ts = BigInt(timestamp) promises.push(bulk.add([[ fingerprint, ts, From f2338ec57bf20b40a1a8fbf61dd2e46d69a01a04 Mon Sep 17 00:00:00 2001 From: akvlad Date: Wed, 29 Jan 2025 13:46:15 +0200 Subject: [PATCH 2/2] fix --- lib/handlers/otlp_log_push.js | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/lib/handlers/otlp_log_push.js b/lib/handlers/otlp_log_push.js index 9e45976e..14f7edfa 100644 --- a/lib/handlers/otlp_log_push.js +++ b/lib/handlers/otlp_log_push.js @@ -30,12 +30,11 @@ async function handle (req, res) { } const labels = stringify(logAttrs) const fingerprint = fingerPrint(labels) - const timestamp = logRecord.timeUnixNano + const ts = logRecord.timeUnixNano ? BigInt(logRecord.timeUnixNano) : logRecord.observedTimeUnixNano ? BigInt(logRecord.observedTimeUnixNano) : BigInt(Date.now()) * BigInt(1000000) - const ts = BigInt(timestamp) promises.push(bulk.add([[ fingerprint, ts,