Как заполнить временные окна без данных в аналитике Kinesis

Есть ли способ запустить анализ кинезиса, когда нет данных, поступающих в поток? Как периодический прогон, несмотря на наличие данных или нет?

У меня есть поток данных от датчика, который выглядит следующим образом:

[
  {
     "timestamp": "2011/09/01 22:30",
     "reading": 1
  },
  {
     "timestamp": "2011/10/01 22:31",
     "reading": 0
  }
]

Мой вариант использования заключается в том, чтобы рассчитать в режиме реального времени секунды, которые reading был 1 в ведрах по 1 минуте.

Пожалуйста, я планирую сделать это, используя только инструменты Kinesis Analytics SQL или AWS, а не сторонние службы, такие как drools или любой другой запуск.

Источник

0 ответов

Другие вопросы по тегам