mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2025-02-19 15:30:17 +00:00
app/{vminsert,vmagent}: use Influx field as metric name if measurement is empty and -influxSkipSingleField command-line is set
See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/1139
This commit is contained in:
parent
1618b0ca6d
commit
6ebf18ab97
2 changed files with 4 additions and 2 deletions
app
|
@ -96,7 +96,8 @@ func insertRows(db string, rows []parser.Row, extraLabels []prompbmarshal.Label)
|
||||||
if !*skipMeasurement {
|
if !*skipMeasurement {
|
||||||
ctx.metricGroupBuf = append(ctx.metricGroupBuf, r.Measurement...)
|
ctx.metricGroupBuf = append(ctx.metricGroupBuf, r.Measurement...)
|
||||||
}
|
}
|
||||||
skipFieldKey := len(r.Fields) == 1 && *skipSingleField
|
// See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/1139
|
||||||
|
skipFieldKey := len(r.Measurement) > 0 && len(r.Fields) == 1 && *skipSingleField
|
||||||
if len(ctx.metricGroupBuf) > 0 && !skipFieldKey {
|
if len(ctx.metricGroupBuf) > 0 && !skipFieldKey {
|
||||||
ctx.metricGroupBuf = append(ctx.metricGroupBuf, *measurementFieldSeparator...)
|
ctx.metricGroupBuf = append(ctx.metricGroupBuf, *measurementFieldSeparator...)
|
||||||
}
|
}
|
||||||
|
|
|
@ -105,7 +105,8 @@ func insertRows(at *auth.Token, db string, rows []parser.Row, extraLabels []prom
|
||||||
if !*skipMeasurement {
|
if !*skipMeasurement {
|
||||||
ctx.metricGroupBuf = append(ctx.metricGroupBuf, r.Measurement...)
|
ctx.metricGroupBuf = append(ctx.metricGroupBuf, r.Measurement...)
|
||||||
}
|
}
|
||||||
skipFieldKey := len(r.Fields) == 1 && *skipSingleField
|
// See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/1139
|
||||||
|
skipFieldKey := len(r.Measurement) > 0 && len(r.Fields) == 1 && *skipSingleField
|
||||||
if len(ctx.metricGroupBuf) > 0 && !skipFieldKey {
|
if len(ctx.metricGroupBuf) > 0 && !skipFieldKey {
|
||||||
ctx.metricGroupBuf = append(ctx.metricGroupBuf, *measurementFieldSeparator...)
|
ctx.metricGroupBuf = append(ctx.metricGroupBuf, *measurementFieldSeparator...)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue