способ установить время отправки данных в Kinesis Analytics, например, каждые 5 минут

Я действительно запутался в том, как работает кинезис и кинезисная аналитика.

Мне нужно отправить некоторые данные в kenisis analytics, а затем десять лучших историй (данные) должны отправляться в лямбда-функцию каждые 5 минут. У меня есть поток Kinesis, а также аналитика Kinesis, настроенная следующим образом:

введите здесь описание изображения

Теперь проблема в том, что всякий раз, когда данные поступают в аналитику, кинез-аналитика отправляет истории прямо в лямбда-выражение, а это не то, чего я хочу. Мне нужно отправлять данные каждые 5 минут. Есть ли способ установить время отправки данных в Kinesis Analytics? Есть идеи?


person Hamed Minaee    schedule 09.01.2018    source источник


Ответы (1)


Вот как я это исправил:

FLOOR(("TRENDING_STORIES_001".ROWTIME - TIMESTAMP  '1970-01-01 00:00:00') SECOND / 40 TO SECOND)
person Hamed Minaee    schedule 16.01.2018