我已经阅读了一些关于Kinesis shard和多个消费者的问题,但是我仍然不理解它是如何工作的。
我的用例:我有一个只有一个shard的Kinesis流。我想使用不同的Lambda函数来消费这个shard,每个函数都是独立的。就像每个Lambda函数都有自己的shard迭代器一样。
这是可能的吗?设置多个Lambda消费者(基于流)从同一流/ shard中读取?
我已经阅读了一些关于Kinesis shard和多个消费者的问题,但是我仍然不理解它是如何工作的。
我的用例:我有一个只有一个shard的Kinesis流。我想使用不同的Lambda函数来消费这个shard,每个函数都是独立的。就像每个Lambda函数都有自己的shard迭代器一样。
这是可能的吗?设置多个Lambda消费者(基于流)从同一流/ shard中读取?
没问题!
分片的数量并不限制一个流可以拥有的消费者数量。在您的情况下,它只会限制每个 Lambda 并发调用的数量。这意味着对于每个消费者,您只能拥有每个分片的并发执行数。
请参见this doc 获取更多详细信息。