Don't set values when pattern doesn't match in regex processor (#4396)
This commit is contained in:
parent
a0ece79191
commit
35d2f90d6c
|
@ -67,7 +67,9 @@ func (r *Regex) Apply(in ...telegraf.Metric) []telegraf.Metric {
|
|||
for _, metric := range in {
|
||||
for _, converter := range r.Tags {
|
||||
if value, ok := metric.GetTag(converter.Key); ok {
|
||||
metric.AddTag(r.convert(converter, value))
|
||||
if key, newValue := r.convert(converter, value); newValue != "" {
|
||||
metric.AddTag(key, newValue)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -75,7 +77,9 @@ func (r *Regex) Apply(in ...telegraf.Metric) []telegraf.Metric {
|
|||
if value, ok := metric.GetField(converter.Key); ok {
|
||||
switch value := value.(type) {
|
||||
case string:
|
||||
metric.AddField(r.convert(converter, value))
|
||||
if key, newValue := r.convert(converter, value); newValue != "" {
|
||||
metric.AddField(key, newValue)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -222,7 +222,7 @@ func TestNoMatches(t *testing.T) {
|
|||
},
|
||||
},
|
||||
{
|
||||
message: "Should emit empty string when result_key given but regex doesn't match",
|
||||
message: "Should not emit new tag/field when result_key given but regex doesn't match",
|
||||
converter: converter{
|
||||
Key: "request",
|
||||
Pattern: "not_match",
|
||||
|
@ -230,8 +230,7 @@ func TestNoMatches(t *testing.T) {
|
|||
ResultKey: "new_field",
|
||||
},
|
||||
expectedFields: map[string]interface{}{
|
||||
"request": "/users/42/",
|
||||
"new_field": "",
|
||||
"request": "/users/42/",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue