Я пытаюсь отключить мой запрос к конденсатору для поиска в течение 5 минут, но начать в прошлом 10 секунд. таким образом, запрос будет для (сейчас - 10 с) до (сейчас - 5m10 с). Это должно компенсировать задержку в данных.
dbrp "telegraf"."Raw"
var process_load = batch
|query('''SELECT sum("ProcessTime")
FROM "telegraf"."Raw".Document
WHERE ("Application" = 'AMP' AND "Environment" = 'test' )
''')
.period(5m)
.every(10s)
.groupBy( 'GroupID' , 'Thread' , time(5m))
|alert()
.stateChangesOnly()
.warn(lambda: "sum" > 90000)
.crit(lambda: "sum" > 240000)
.log('/tmp/document.test.log')
В настоящее время приёмный приемник получает данные от телеграфа, но из-за задержки запрос отправляет предупреждающее сообщение, даже если оно имеет критическое значение. в настоящее время он отправляет предупреждение и критическое переключение между ними. Он должен стать критическим и оставаться там до тех пор, пока не прекратится поток документов.