Kinesis 分片迭代器说明

Question

我正在尝试从 Kinesis 分片获取记录。我循环获取分片迭代器，然后获取迭代器中的记录。我似乎得到了无数的迭代器，但没有一个包含任何记录。

我的问题涉及迭代器的寿命。鉴于 Kinesis 仅保存数据 24 小时，而迭代器的生命周期应为 5 分钟，难道我在任何时间点都只能看到最多 288 个迭代器吗？

Answer 1

分片迭代器的数量没有固定值，因为分片迭代器只是给定记录的给定分片中的唯一位置。

分片迭代器只是分片中某个点给定记录的序列号。

根据此处的文档：

序列号是与流中摄取的每个记录相关联的标识符，并在将记录放入流中时分配。每个流都有一个或多个分片

分片迭代器指定分片位置，从该位置开始顺序读取数据记录。

因此，从上面我相信分片迭代器实际上是一个基于时间戳的任意 ID。

该位置是使用分片中数据记录的序列号指定的。

所以迭代器的数量实际上与给定分片中的记录数量更密切相关。