Каково было бы поведение, когда 2 лямбды имеют одинаковый поток кинезиса? - PullRequest
0 голосов
/ 21 апреля 2020

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

Как будет выглядеть поведение, если я добавлю KinesisA к триггеру потока LambdaA и LambdaB?

Будут ли сообщения из KinesisA циклически переупорядочены между двумя лямбдами или обе лямбды каждая получат одинаковую копию сообщений?

1 Ответ

2 голосов
/ 21 апреля 2020

Вскоре; у каждого потребителя будет одна и та же копия сообщения, пока он использует поток кинезиса. Для каждого потребителя кинезиса существует индивидуальный возраст итератора (по умолчанию 24 часа - до 7 дней).

Означает, что если одна из ваших лямбда не потребляет, а через 10 часов начинает потреблять, он будет потреблять поток с того места, где он ушел.

Вы можете настроить разные размеры пакета для каждого потребителя ( одна лямбда может иметь 25, другая только 1)

...