У меня есть поток кинезиса с 2 осколками. Я хотел бы знать, возможно ли следующее с lambdas:
- На стороне производителя я хотел бы настроить 2 производителя лямбда-данных для записи в поток, и каждый производитель будет писать в свой собственный шард (назовите их A и B).
- Что касается потребителя, я бы хотел, чтобы еще 2 лямбды (назовите их A 'и B') потребляли записи и обрабатывали только их собственные осколки.
Возможно ли это? Получает ли каждый потребитель лямбда все сообщения из потока kinesis и должен ли сам применять фильтрацию? Или они могут получать только сообщения от определенного шарда? Как это работает?