Я уже некоторое время смотрю на аналитику AWS Kinesis, и я изо всех сил пытаюсь заставить работать следующий сценарий:
Допустим, у вас есть Firehose, который подключен к Kinesis Analytics в качестве входного потока.Этот пожарный шланг предназначен для вывода данных каждые 60 с .Я записываю данные в этот Firehose каждые 2 с или около того , например: {"value":1}.Где 1 - случайное целое число (может быть 1, 5, 32 и т. Д.).
Как мне написать аналитику, чтобы найти среднее значение всех значений, о которых сообщалось в последние 60-е годы, и передать его лямбде?
Я пытался использовать различные окна - однако аналитика, похоже, выводит данные каждые несколькосекунд вместо 60 с.