如何在CloudWatch订阅中分配特定的Kinesis Shard

Question

如果您计划向特定的Kinesis流订阅的CloudWatch日志数据超过单个碎片所能处理的数据量，是否可以通过添加多个碎片来扩展流，然后将多个CloudWatch日志订阅分布到这些碎片上？

这里的文档有点掩盖了分片处理，只提到“ShardId-000000000000”。

API文档（至少对于.NET SDK而言）建议在创建订阅时指定目标arn，但我的理解是，arn不能比运动流更具体，但我不认为为单个碎片分配arn。

从本质上讲，如果您计划订阅的CloudWatch数据超过单个shard所能处理的数据量，是否有办法将您的流“扩展”到多个shard流中（同时使用CloudWatch订阅并避免编写自定义客户端来处理数据），或者是否有必要将其“扩展”到多个单个shard流中？

Answer 1

我从我所在组织的AWS代表处收到了以下答复：

CloudWatch订阅基于以下所有参数在内部为每条消息创建一个PartitionKey：ownerId、logGroupName和logStreamName。

基于留档中没有提及，我假设分片分区键几乎被CloudWatch订阅系统忽略了，但看起来你会自动获得一个相当不错的机制来在流的分片中分发消息。