Amazon DynamoDB Streams 推出了一项新的 API 功能，可更快、更高效地发现流分片

发布于: 2025年7月17日

现在，Amazon DynamoDB Streams 在 DescribeStream API 中支持一个新的 ShardFilter 参数，以简化和优化流式数据的使用。您可以在父分片关闭后使用 ShardFilter 参数快速发现子分片，从而显著提高处理 DynamoDB Streams 数据时的效率和响应能力。

DynamoDB Streams 是一项无服务器数据流功能，可以近乎实时地直接跟踪、处理和响应 DynamoDB 表中的项目级变化。DynamoDB Streams 支持多种变更数据捕获使用案例，包括构建事件驱动型应用程序、数据复制、审计以及实施数据分析和机器学习功能。如果应用程序使用来自 DynamoDB Streams 的数据，则可以使用这个可选的 ShardFilter 参数高效地从读取封闭分片切换到其子分片，从而避免重复调用 DescribeStream API 来检索和遍历所有封闭和开放分片的分片映射。此 API 增强功能有助于确保在分片之间切换时实现更顺畅的切换和更低的延迟，从而提升流处理应用程序的响应速度与成本效益。

这个新的 ShardFilter 参数现已在所有 AWS 区域推出。您可以通过 AWS API、Kinesis 客户端库 (KCL) 3.0 或适用于 DynamoDB Streams 的 Apache Flink 连接器开始使用该功能。使用 AWS Lambda 以使用 DynamoDB Streams 的客户将自动获享这一增强的 API 体验。

有关更多信息，请参阅《DynamoDB 开发人员指南》中的使用 DynamoDB Streams 以及 DescribeStream API 参考。