Оповещения работают нормально с файлом журнала, но не с InfluxDBOut при записи одинаковых данных - PullRequest
Новая
       30

Оповещения работают нормально с файлом журнала, но не с InfluxDBOut при записи одинаковых данных

0 голосов
/ 30 мая 2019

Я использую InfluxDB с Kapacitor 1.5.2 и написал простой скрипт TICK, найденный в онлайн-справке InfluxDB.То, что я хочу сделать, это обнаружить скачки в моем измерении.Код взят из интерактивной справки InfluxDB, и вывод в файл журнала работает отлично при добавлении новых данных, которые вызывают предупреждение.Однако уже несколько часов я пытаюсь вывести эти оповещения обратно в InfluxDB, но безуспешно.Я прочитал большинство постов в блоге / попробовал большинство комбинаций / перечитал онлайн-справку InfluxDB, но не могу сделать эту работу.Измерение «предупреждений» никогда не создается, даже если вызывается (create ()). 

// Parameters
var infoSig = 2.5
var warnSig = 3
var critSig = 3.5
var dbName = 'mydb'
var rPolicy = 'autogen'
var measurementSource = 'cpu'
var measurementAlertDest = 'alerts'

// Dataframe
var data = stream
    |from()
        .database(dbName)
        .retentionPolicy(rPolicy)
        .measurement(measurementSource)
        .groupBy('dimval')

// Thresholds
var alert = data
    |eval(lambda: sigma("v"))
        .as('sigma')
        .keep()
    |alert()
        .id('{{ index .Tags "dimval"}}')
        .message('{{ .ID }}:{{ index .Fields "stat" }}')
        .info(lambda: "sigma" > infoSig)
        .warn(lambda: "sigma" > warnSig)
        .crit(lambda: "sigma" > critSig)
    // And back to DB as well == this doesn't have any effect at all
    |influxDBOut()
        .create()
        .database(dbName)
        .measurement(measurementAlertDest)

// When I comment the block above and uncomment the block below, I get logs in the file below
//alert
//        .log('/tmp/alerts.log')
//        .mode(0644)

Ничего в журнале ошибок в журналах Kapacitor (/ var / log / kapacitor), но очевидно, что притокDBOut () не делаеткажется, не имеет никакого эффекта, так как измерение не создано.Я что-то здесь упускаю?

...