经过审慎考虑,我们决定自 2026 年 1 月 27 日起终止对 Amazon Kinesis Data Analytics for SQL 应用程序的支持。我们建议您使用适用于 Apache Flink 的亚马逊托管服务。适用于 Apache Flink 的亚马逊托管服务集简单易用和高级分析功能于一体,它使您能够在几分钟内构建流处理应用程序。您可以我们的文档部分查找代码和架构示例,以帮助您将 Kinesis Data Analytics for SQL 工作负载迁移到适用于 Apache Flink Studio 的亚马逊托管服务。
有关 KPU 使用的一般性指导
我们建议您使用生产负载测试应用程序,以准确估算应用程序需要的 KPU 数量。KPU 使用量根据数据量和速度、代码复杂度、集成等可能有很大差异,尤其是在 Amazon Kinesis Data Analytics 中使用 Apache Flink 运行时的情况下。例如,通过内部测试,我们观察到没有状态的简单应用程序每个 KPU 每秒有数百 MB 吞吐量;而使用密集机器学习(ML)算法的复杂应用程序每秒吞吐量不足 1MB。考虑到这些情况,在测试应用程序之前,我们提供的一般性指导是每个 KPU 每秒 1MB。
定价
中国(宁夏)区域:
Kinesis 处理单元(每小时) | 每小时 ¥0.777 |
中国(北京)区域:
Kinesis 处理单元(每小时) | 每小时 ¥ 1.161 |
定价示例
针对 Kinesis 流中捕获的在线购物交易中销售的商品,客户使用 Amazon Kinesis Data Analytics 中的 SQL 应用程序来计算 1 分钟内这些商品的滑动窗口总量。数据流摄入数据的速率通常为 1000 条记录/秒,但是数据在促销活动期间每天会出现一次达到 6000 条记录/秒的峰值,时间不超过一个小时。Amazon Kinesis Data Analytics 月度费用将根据以下方式进行计算:
月度费用
中国(宁夏)区域用于流处理应用程序的价格为每 KPU 每小时 ¥0.777。传入的 Kinesis 数据流的传输数据速度为 1000 条记录/秒。但该数据流每天会出现一次 6000 条记录/秒的峰值,时间不超过一个小时。
对于一天 24 小时中有 23 个小时处于“稳定状态”情况,滑动窗口查询在这些时间使用 1 KPU 处理工作负载。
30 天/月 * 23 小时/天 = 690 小时/月
稳定状态费用 = 690 小时/月 *(1 KPU * ¥0.777/小时)= ¥536.13
对于一天 24 小时中有 1 个小时处于“峰值状态”情况,滑动窗口查询使用 1 至 2 个 KPU。全天 24 小时中的这 1 个小时,将按 2 个 KPU 向客户计费。
30 天/月 * 1 小时/天 = 30 小时/月
峰值状态费用 = 30 小时/月 * (2 KPU * ¥0.777/小时) = ¥46.62
注意:我们保留对传入和传出 Amazon Kinesis Data Analytics 应用程序的数据收取标准数据传输费用的权利。