亚马逊运动：记录每个碎片

Question

我有一个亚马逊运动流，由多个碎片组成。碎片的数量，因此消费者的数量，不是一个常数。

有一种不常见的事件类型，我希望广播给流中的每个消费者。

制作人是否有办法播放一张唱片，即发现碎片并将唱片放在每个碎片上？

Answer 1

你能做到的！有点...

诀窍是使用参数“ExplicitHashKey”。

这允许您设置用于记录的哈希键，因此允许您选择数据正在进行的分片。

然后你可以打电话

aws kinesis describe-stream --stream-name name-of-your-stream

获取有关每个分片的信息，包括每个分片涵盖的哈希范围。

然后，您只需要将数据发送到每个碎片（使用PutRecord或PutRecords），就可以完成所有设置。

不幸的是，没有“广播”，但您可以轻松编写Lambda，使用ExplicitHashKey参数将相同的数据发送到每个碎片。

另一种解决方案是使用单独的流并对每个流进行写出。