Kapacitor時間序列數(shù)據(jù)監(jiān)控框架

Kapacitor 是一個開源框架，用來處理、監(jiān)控和警告時間序列數(shù)據(jù)。Kapacitor 使用 TICKscript 腳本來定義任務，示例代碼：

stream
    .from().measurement('cpu_usage_idle')
    .groupBy('host')
    .window()
        .period(1m)
        .every(1m)
    .mapReduce(influxql.mean('value'))
    .eval(lambda: 100.0 - "mean")
        .as('used')
    .alert()
        .message('{{ .Level}}: {{ .Name }}/{{ index .Tags "host" }} has high cpu usage: {{ index .Fields "used" }}')
        .warn(lambda: "used" > 70.0)
        .crit(lambda: "used" > 85.0)

        // Send alert to hander of choice.

        // Slack
        .slack()
        .channel('#alerts')

        // VictorOps
        .victorOps()
        .routingKey('team_rocket')

        // PagerDuty
        .pagerDuty()

執(zhí)行方法：

# Define the task (assumes cpu data is in db 'telegraf')kapacitor define \
    -name cpu_alert \
    -type stream \
    -dbrp telegraf.default \
    -tick ./cpu_alert.tick# Start the taskkapacitor enable cpu_alert