You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
For debugging purposes, I should be able to insert httpOut node wherever I want, like so:
var data = stream.from().database('telegram').retentionPolicy('biweekly')
.measurement('cassandra')
.where(lambda: "table" == 'metrics3')
data.derivative('local_write_count').NonNegative()
.window().period(300s).every(60s)
.mapReduce(influxql.mean('local_write_count'))
.httpOut('local_write_count')
.alert()
.crit(lambda: "mean" < 3500)
.message('Cassandra local writes for metics3 table is below 3500 per second.')
.stateChangesOnly().pagerDuty()
But currently, this is not working:
invalid task: No method or property "alert" on *pipeline.HTTPOutNode
So, now just to debug, I have to rewrite it like this:
var data = stream.from().database('telegram').retentionPolicy('biweekly')
.measurement('cassandra')
.where(lambda: "table" == 'metrics3')
var s1 = data.derivative('local_write_count').NonNegative()
.window().period(300s).every(60s)
.mapReduce(influxql.mean('local_write_count'))
s1.httpOut('local_write_count')
s1.alert()
.crit(lambda: "mean" < 3500)
.message('Cassandra local writes for metics3 table is below 3500 per second.')
.stateChangesOnly().pagerDuty()
And now it looks ugly.
The text was updated successfully, but these errors were encountered:
@rubycut This is a simple fix. Also note that a LogNode was just added that does work the way you want and it logs all data it receives to the Kapacitor log. You can try it in last nights build.
For debugging purposes, I should be able to insert httpOut node wherever I want, like so:
But currently, this is not working:
invalid task: No method or property "alert" on *pipeline.HTTPOutNode
So, now just to debug, I have to rewrite it like this:
And now it looks ugly.
The text was updated successfully, but these errors were encountered: