Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-20 07:19:17 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

lib/protoparser/csvimport: add missing metric vm_rows_invalid_total{type="csvimport"}

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2020-03-12 15:27:45 +02:00
parent c1551a3269
commit c8dc1cd218
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/protoparser/csvimport/parser.go
View File

@ -4,6 +4,7 @@ import (
"fmt" "fmt"
"github.com/VictoriaMetrics/VictoriaMetrics/lib/logger" "github.com/VictoriaMetrics/VictoriaMetrics/lib/logger"
"github.com/VictoriaMetrics/metrics"
"github.com/valyala/fastjson/fastfloat" "github.com/valyala/fastjson/fastfloat"
) )
@ -119,6 +120,7 @@ func parseRows(sc *scanner, dst []Row, tags []Tag, metrics []metric, cds []Colum
} }
if sc.Error != nil { if sc.Error != nil {
logger.Errorf("error when parsing csv line %q: %s; skipping this line", line, sc.Error) logger.Errorf("error when parsing csv line %q: %s; skipping this line", line, sc.Error)
invalidLines.Inc()
continue continue
} }
if len(metrics) == 0 { if len(metrics) == 0 {
@ -139,3 +141,5 @@ func parseRows(sc *scanner, dst []Row, tags []Tag, metrics []metric, cds []Colum
} }
return dst, tags, metrics return dst, tags, metrics
} }
var invalidLines = metrics.NewCounter(`vm_rows_invalid_total{type="csvimport"}`)