Kapacitor是一个开源框架，用来处理、监控和警告时间序列数据。Kapacitor使用TICKscript脚本来定义任务，示例代码：
stream .from().measuremet('cpu_usage_idle') .groupBy('host') .widow() .period(1m) .every(1m) .mapReduce(ifluxql.mea('value')) .eval(lambda: 100.0 - "mea") .as('used') .alert() .message('{{ .Level}}: {{ .Name }}/{{ idex .Tags "host" }} has high cpu usage: {{ idex .Fields "used" }}') .war(lambda: "used" > 70.0) .crit(lambda: "used" > 85.0) // Sed alert to hader of choice. // Slack .slack() .chael('#alerts') // VictorOps .victorOps() .routigKey('team_rocket') // PagerDuty .pagerDuty()执行方法：
# Defie the task (assumes cpu data is i db 'telegraf')kapacitor defie \ -ame cpu_alert \ -type stream \ -dbrp telegraf.default \ -tick ./cpu_alert.tick# Start the taskkapacitor eable cpu_alert
评论