From a1988d3c70f89c31488a5c2a3b5dc2e32f64197b Mon Sep 17 00:00:00 2001 From: Marco Colombo Date: Tue, 17 Sep 2024 12:15:08 +0200 Subject: [PATCH] shift to avoid time alignment ingestion problems --- business/tsextractor/tsextractor.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/business/tsextractor/tsextractor.go b/business/tsextractor/tsextractor.go index c1955f7..4874cec 100755 --- a/business/tsextractor/tsextractor.go +++ b/business/tsextractor/tsextractor.go @@ -50,6 +50,10 @@ func computeTimeAlignment(resolutionSeconds, timeWindowInMinutes int) (time.Time resolutionSeconds = 300 // Align to 5 minutes } to := time.Now().Truncate(time.Duration(resolutionSeconds) * time.Second).UTC() + if resolutionSeconds <= 900 { + // Shift time window to avoid missing data + to = to.Add(-time.Duration(300) * time.Second) + } from := to.Add(-time.Duration(timeWindowInMinutes) * time.Minute) return from, to }