From a505fc570926193780393e60975a2df351eb45f0 Mon Sep 17 00:00:00 2001 From: Joerg Lehmann Date: Mon, 23 Aug 2021 13:35:35 +0200 Subject: [PATCH] field order has changed with influxdb 2.0.8 --- metrics.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/metrics.go b/metrics.go index 239d5e8..d3b6fab 100644 --- a/metrics.go +++ b/metrics.go @@ -164,10 +164,10 @@ func metricsHandler(response http.ResponseWriter, request *http.Request) { for scanner.Scan() { s := strings.Split(scanner.Text(), ",") fmt.Printf("Scanned Line: %v, %d elements\n", s, len(s)) - if (len(s) >= 12) && !(strings.HasPrefix(s[3], "_")) { - t, err := time.Parse(time.RFC3339, s[3]) + if (len(s) >= 12) && !(strings.HasPrefix(s[5], "_")) { + t, err := time.Parse(time.RFC3339, s[5]) if err != nil { - fmt.Printf("error converting time: %s\n", s[3]) + fmt.Printf("error converting time: %s\n", s[5]) continue } a := t.Unix() @@ -317,7 +317,7 @@ func downloadmetricsHandler(response http.ResponseWriter, request *http.Request) for scanner.Scan() { s := strings.Split(scanner.Text(), ",") fmt.Printf("Scanned Line: %v, elements: %d\n", s, len(s)) - if (len(s) >= 10) && !(strings.HasPrefix(s[3], "_")) { + if (len(s) >= 10) && !(strings.HasPrefix(s[5], "_")) { s_flags := "" lat := s[len(s)-2] lon := s[len(s)-1] @@ -335,9 +335,9 @@ func downloadmetricsHandler(response http.ResponseWriter, request *http.Request) s_flags = s_flags + "+OUTSIDE_GREENZONE" } } - t, err := time.Parse(time.RFC3339, s[3]) + t, err := time.Parse(time.RFC3339, s[5]) if err != nil { - fmt.Printf("error converting time: %s\n", s[3]) + fmt.Printf("error converting time: %s\n", s[5]) continue } mytime := t.In(location).Format("02.01.2006 15:04") @@ -450,10 +450,10 @@ func getLastMetrics(deveui string) OneMetric { for scanner.Scan() { s := strings.Split(scanner.Text(), ",") fmt.Printf("BlaBla: %v, elements: %d\n", s, len(s)) - if (len(s) >= 12) && !(strings.HasPrefix(s[3], "_")) { - t, err := time.Parse(time.RFC3339, s[3]) + if (len(s) >= 12) && !(strings.HasPrefix(s[5], "_")) { + t, err := time.Parse(time.RFC3339, s[5]) if err != nil { - fmt.Printf("error converting time: %s\n", s[3]) + fmt.Printf("error converting time: %s\n", s[5]) continue }