发布于: Aug 18, 2020

Amazon Kinesis Data Streams宣布推出两项新的 API 功能,旨在对使用 Kinesis Data Streams 数据的应用程序进行简化。第一个功能是 ListShards API 中的可选筛选字段,您可使用它来为希望从数据流中列出的碎片设置筛选条件。例如,要列出带有特定时间点数据的碎片,您现在可以使用时间戳筛选条件。第二个功能是 GetRecords 和 SubscribeToShards 的 API 中一个名为 ChildShards 的新字段,借助它,您便能够发现封闭分片的子分片(而不必使用 ListShards API 来列出所有封闭分片和开放分片)。对于使用的是来自 Kinesis Data Streams 的数据的应用程序来说,可使用此新字段将读取从封闭的分片高效地转换为从其子分片读取。这是由于流伸缩操作导致分片关闭时使用应用程序时遇到的常见用例。 

Kinesis Client Library (KCL)可处理复杂的问题(例如适应流量的变化,负载平衡流数据,协调分布式工作程序以及处理具有容错能力的数据),因而可帮助您快速构建自定义的消费者应用程序。通过使用 KCL,您可在构建消费应用程序的同时专注于业务逻辑。使用最新 KCL 版本(标准用户使用的是 KCL 1.14,EFO 用户使用的是 KCL 2.3)的客户将自动从这两项新功能中受益。 

Amazon Kinesis Data Streams 是一种可大规模扩展且持久的实时数据流服务。它每秒可从数十万个源(例如网站点击流、IoT 数据、数据库事件流、财务交易、社交媒体供稿、IT 日志和位置跟踪事件)连续捕获数 GB 的数据。收集的数据在毫秒之内即可用于控制面板、异常检测、动态定价等实时分析用例。 

有关更多信息,请参阅“Amazon Kinesis Data Streams 开发人员指南”和 ListShardsGetRecordsSubscribeToShardAPI 参考中的“从 kinesis 数据流中读取数据”版块。这些 API 增强版功能及最新的KCL 版本,在所有已推出 Amazon Kinesis Data Streams的AWS 地区均已可用。