Я пытаюсь создать тиковый скрипт, который сокращает данные.Для этого я использую интеграл, так как я хочу кВт / ч.Сценарий выглядит следующим образом:
batch
|query('SELECT INTEGRAL("value", 1h) FROM "iotawatt"."autogen"."Main"')
.every(5m)
.groupBy(time(1h))
|influxDBOut()
.database('iotawatt')
.retentionPolicy('autogen')
.measurement('Main_hourly2')
Это приводит к следующей ошибке:
не удалось выполнить синтаксический анализ запроса InfluxQL: недопустимое количество аргументов для интеграла, ожидается 1, получено 2
После этой ошибки я удалил 2-й аргумент, и проблема решена.Но мне действительно нужно определить единицу.Ранее я работал с интегралом, чтобы создать непрерывный запрос для достижения той же цели, и интеграл принял второй аргумент.Поскольку cq не дает мне возможности отложить понижающую дискретизацию (данные с метками времени отправляются пакетами и поступают позже, чем выполняется cq), я переключился на Kapacitor.
Согласно документам,он действительно должен принять второй аргумент: https://docs.influxdata.com/influxdb/v1.6/query_language/functions/#integral
Я что-то не так делаю?
Спасибо за вашу помощь !!!