Мне нужно обработать данные из потока AWS Kinesis, который собирает события с устройств. Функция обработки должна вызываться каждую секунду со всеми событиями, полученными за последние 10 секунд. Скажем, у меня есть два устройства A и B,...

Из KinesisClientRecord (записи), которую я получил с помощью клиента KCL, я могу получить объект JSON, представляющий событие обновления ddb из потока, выполнив следующие действия: String recordData =...