假设我有2个Lambda,即LambdaA
和LambdaB
。两个lambda都是independent lambda,它们中具有different函数。我还有一个名为KinesisA
的Kinesis,它是一个数据流without,将任何内容设置为其使用者选项。
如果我将KinesisA
添加到LambdaA
和LambdaB
的流触发器中,将会是什么样的行为?
来自KinesisA
的消息将在两个lambda之间轮循,还是两个lambda 每个会收到相同的copy消息?
简短地说;每个使用者在使用运动流时都将具有相同的消息副本。每个运动消费者都有一个单独的迭代器年龄(默认为24小时-最多7天)。
表示如果您的lambda之一没有消耗,而10个小时后开始消耗,那么他将从他离开的地方消耗流。
您可以为每个消费者配置不同的批处理大小(一个lambda可能有25个,另一个仅为1)