发布于: Jul 17, 2025
Amazon DynamoDB Streams 现在在 DescribeStream API 中支持一个新的 ShardFilter 参数，以简化并优化流式传输数据的使用。在关闭父分片后，您可以使用 ShardFilter 参数快速发现子分片，从而显著提高处理来自 DynamoDB Streams 的数据时的效率和响应能力。
DynamoDB Streams 是一项无服务器数据流式传输功能，可以近乎实时地直接跟踪、处理并响应 DynamoDB 表中的项目级变化。DynamoDB Streams 支持多种变更数据捕获使用案例，包括构建事件驱动型应用程序、数据复制、审计以及实现数据分析和机器学习功能。使用来自 DynamoDB Streams 数据的应用程序可以使用此可选的 ShardFilter 参数高效地从读取已关闭分片过渡到其子分片，从而避免重复调用 DescribeStream API 来检索和遍历所有已关闭和已打开分片的分片地图。此 API 增强功能有助于确保在分片之间切换时实现更顺畅的过渡和更低的延迟，从而使您的流处理应用程序的响应速度更快，更具成本效益。
新的 ShardFilter 参数已在由光环新网运营的亚马逊云科技中国（北京）区域和由西云数据运营的亚马逊云科技中国（宁夏）区域推出。您可以使用 Amazon API、Kinesis Client Library（KCL）3.0 或适用于 DynamoDB Streams 的 Apache Flink 连接器开始使用该功能。使用 Amazon Lambda 使用 DynamoDB Streams 的客户将自动受益于这种增强的 API 体验。
有关更多信息，请参阅 DynamoDB 开发人员指南中的使用 DynamoDB Streams 和 DescribeStream 的 API 参考。