diff --git a/kapacitor/client_test.go b/kapacitor/client_test.go index ee82e2d23..88bc04e79 100644 --- a/kapacitor/client_test.go +++ b/kapacitor/client_test.go @@ -214,6 +214,9 @@ var trigger = data .durationField(durationField) trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -300,6 +303,9 @@ var trigger = data .durationField(durationField) trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -540,6 +546,9 @@ var trigger = data .durationField(durationField) trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -623,6 +632,9 @@ var trigger = data .durationField(durationField) trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -1376,6 +1388,9 @@ trigger |eval(lambda: "emitted") .as('value') .keep('value', messageField, durationField) + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) diff --git a/kapacitor/influxout.go b/kapacitor/influxout.go index f7e1fca89..b0cfe0719 100644 --- a/kapacitor/influxout.go +++ b/kapacitor/influxout.go @@ -20,11 +20,14 @@ func InfluxOut(rule chronograf.AlertRule) (string, error) { return fmt.Sprintf(` trigger %s + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() - .create() - .database(outputDB) - .retentionPolicy(outputRP) - .measurement(outputMeasurement) + .create() + .database(outputDB) + .retentionPolicy(outputRP) + .measurement(outputMeasurement) .tag('alertName', name) .tag('triggerType', triggerType) `, rename), nil diff --git a/kapacitor/influxout_test.go b/kapacitor/influxout_test.go index 87b6ee7c3..39489750d 100644 --- a/kapacitor/influxout_test.go +++ b/kapacitor/influxout_test.go @@ -14,6 +14,9 @@ func TestInfluxOut(t *testing.T) { |eval(lambda: "emitted") .as('value') .keep('value', messageField, durationField) + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) diff --git a/kapacitor/tickscripts_test.go b/kapacitor/tickscripts_test.go index 4af735616..eb78e3056 100644 --- a/kapacitor/tickscripts_test.go +++ b/kapacitor/tickscripts_test.go @@ -181,6 +181,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -323,6 +326,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -467,6 +473,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -620,6 +629,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -772,6 +784,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -924,6 +939,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -1059,6 +1077,9 @@ var trigger = data .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -1222,6 +1243,9 @@ var trigger = past .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -1385,6 +1409,9 @@ var trigger = past .email() trigger + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB) @@ -1527,6 +1554,9 @@ trigger |eval(lambda: "emitted") .as('value') .keep('value', messageField, durationField) + |eval(lambda: float("value")) + .as('value') + .keep() |influxDBOut() .create() .database(outputDB)