当前位置: 首页 > 知识库问答 >
问题:

AWS使用多个碎片重新读取数据的运动顺序

柳德义
2023-03-14

让我们假设,有一个消费者与多个工作者一起从同一个运动流的多个碎片中读取数据。我们决定从某个时间点开始重新读取所有记录。订单是否保证与第一次阅读时相同?我知道,从单个碎片读取时应该是这样。但是,在处理多个碎片时,它是否以某种方式在幕后得到了解决?

共有1个答案

谢旭
2023-03-14

Kinesis仅保证每次读取时每个碎片的数据顺序。它不能保证所有碎片组合的数据顺序<因此,要回答您的问题,是的,顺序将与您第一次阅读的顺序相同。

 类似资料:
  • 我读过很多关于这方面的文章,但也有2012年或更早的文章。 (我只是打算从数据库中读取和插入一些数据。)

  • 我已经读过一些关于动画片和多个消费者的问题,但我仍然不明白它是如何工作的。 我的用例:我有一个只有一个分片的运动流。我想使用不同的lambda函数使用这个分片,每个函数都独立。就像每个lambda函数都有自己的分片迭代器一样。 有可能吗?是否设置多个lambda使用者(基于流)从同一流/碎片读取?

  • 我不熟悉Kinesis数据流,我想知道Kinesis数据流的行为是否类似于DDB流中的DynamoDB流行为,一个分区键只能属于一个shard,而一个shard可以容纳多个键。 Kinesis数据流也是如此吗?

  • 简单问题:我想在Amazon上运行一个autoscale组,它会启动多个实例来处理来自SQS队列的消息。但我怎么知道这些实例没有处理相同的消息呢? 我可以在处理消息时将其从队列中删除。但如果它还没有被删除,并且仍由一个实例处理,那么另一个实例可以下载相同的消息,并对其进行处理。

  • 我可以使用一个片段作为一个活动吗?我已经创建了一个片段,但我希望它有像活动一样的功能,所以我使用片段扩展碎片活动。然而,我有一个带有碎片的导航抽屉。当我更改为“扩展碎片活动”时,我的代码有问题?请给我指路。

  • 我有一个亚马逊运动流,由多个碎片组成。碎片的数量,因此消费者的数量,不是一个常数。 有一种不常见的事件类型,我希望广播给流中的每个消费者。 制作人是否有办法播放一张唱片,即发现碎片并将唱片放在每个碎片上?