仅针对特定分区键在Kinesis Stream上读取数据记录

Cra*_*and 5 publish-subscribe amazon-web-services live-streaming amazon-kinesis

首先,非常感谢你考虑我的问题.希望它不是太傻.

我只是想知道是否有一种方法可以在将数据记录从流中取出时过滤Kinesis Stream上的数据.AWS官方文档说分区密钥用于

"允许处理特定分片的消费者设计时假设具有相同分区键的记录只会发送给该消费者"

没有办法指定(既不使用REST API,也不使用KCL)我有兴趣直接读取数据记录的分区键.


具有相同分区键的数据记录将被散列到相同的分片,但是我们只知道分区键就可以知道它是哪个分片?

最终的问题是:如何创建仅接收特定分区密钥数据的使用者?/ 我如何创建仅接收其感兴趣的数据的消费者.

非常感谢您花时间考虑我的问题并分享您的想法!

one*_*ing -1

您可以使用 SNS异步重新调用您的函数。

在这里阅读更多内容,我回答了类似的问题:/sf/answers/3589732191/