发布于: Aug 18, 2020

Amazon Kinesis Data Streams 宣布推出两项新的 API 功能,以简化使用 Kinesis Data Streams 中数据的应用程序。第一项功能是 ListShards API 中的一个可选筛选字段,使您能够为您想要从数据流中列出的分区设置筛选条件。例如,您现在可以使用时间戳筛选条件来列出在某个时间点有数据的分区。第二项功能是 GetRecords API 和 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 开发人员指南》中的读取 Kinesis Data Streams 中的数据以及针对 ListShards、GetRecords 和 SubscribeToShard 的 API 参考。这些 API 增强功能以及最新的 KCL 版本已在由光环新网运营的 亚马逊云科技中国(北京)区域和由西云数据运营的 亚马逊云科技中国(宁夏)区域推出。