只需单击一下,即可使用适用于 Apache Flink 的亚马逊托管服务蓝图构建端到端流管道。了解详情。
简介
使用 Apache Flink 实时转换和分析流媒体数据
借助适用于 Apache Flink 的亚马逊托管服务,您可以使用 Apache Flink(一种用于处理数据流的开源框架和引擎)实时转换和分析流数据。适用于 Apache Flink 的亚马逊托管服务简化了构建和管理 Apache Flink 工作负载的过程,并且可帮助您更轻松地将应用程序与其他 AWS 服务集成。
使用适用于 Apache Flink 的亚马逊托管服务,您只需为实际使用量付费。您无需预置资源,也无需支付预付费用。我们根据用于运行应用程序的 Kinesis 处理单元(KPU)的数量,按小时收取费用。一个简单的 KPU 由 1 个负责计算的 vCPU 和 4GB 存储空间组成。
适用于 Apache Flink 的亚马逊托管服务串流应用程序定价
对于 Apache Flink 应用程序,每个应用程序要为编排收取一个额外的 KPU 费用。应用程序会被收取运行存储和持久备份的费用。运行应用程序存储用于适用于 Apache Flink 的亚马逊托管服务中的有状态处理功能,并按每月每 GB 收费。持久备份是可选项,用于为应用程序提供时间点恢复,按每月每 GB 收费。
在串流模式下,适用于 Apache Flink 的亚马逊托管服务会随着内存和计算需求的波动自动扩展流处理应用程序所需的 KPU 数量。您可以选择以所需的 KPU 数量预置您的应用程序。
适用于 Apache Flink Studio 的亚马逊托管服务定价
在交互式模式下,您将为每个 Studio 应用程序的两个额外 KPU 付费。其中一个 KPU 将用于 Apache Flink 应用程序编排,而另一个将用于无服务器的交互式开发环境。您还将为有状态处理功能所用的运行应用程序存储空间付费。运行应用程序存储将按每月每 GB 的标准付费。
在 Studio 笔记本中进行开发时,您无法选择创建持久应用程序的备份。不过,当您在 Studio 笔记本中将应用程序从交互式模式部署为流式处理模式时,您可以创建持久应用程序的备份。
一般 KPU 使用指导
我们建议您使用生产负载测试您的应用程序,以准确估计您的应用程序所需的 KPU 数量。KPU 使用量可能会因您的数据量和速度、代码复杂性、集成等因素而有很大差异。在适用于 Apache Flink 的亚马逊托管服务中使用 Apache Flink 运行时系统时尤其如此。例如,通过内部测试,我们发现对于无状态的简单应用程序,每个 KPU 的吞吐量为每秒数百 MB,对于使用密集型机器学习(ML)算法的复杂应用程序,每个 KPU 的吞吐量低于每秒 1 MB。考虑到这些注意事项,我们在测试您的应用程序之前提供的一般性指导是每个 KPU 为每秒 1MB。