Блог

У меня есть лямбда-функция AWS, которая запускается при каждой записи Kinesis, когда она попадает в Kinesis. Тем не менее, я хочу запустить лямбда-функцию с определенным количеством сообщений.

Например, я хочу запустить лямбда-функцию с 5 сообщениями, а не с 1.

Вы можете указать максимальное количество записей, которые вы хотите получить, используя Limit параметр GetRecords запроса, но фактическое количество получаемых вами сообщений может быть меньше этого значения. Это невозможно контролировать. Это зависит в основном от объема записей, поступающих в поток.