简介
使用 Apache Flink 实时转换和分析流式传输数据
借助适用于 Apache Flink 的亚马逊托管服务，您可以使用 Apache Flink（一种用于处理数据流的开源框架和引擎）实时转换和分析流式传输数据。适用于 Apache Flink 的亚马逊托管服务简化了构建和管理 Apache Flink 工作负载的过程，并且可帮助您更轻松地将应用程序与其他 AWS 服务集成。
使用适用于 Apache Flink 的亚马逊托管服务，您需要按时长和 KPU 数量付费，以 1 秒为增量计费。一个简单的 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。
按 AWS 区域定价
定价示例
全部打开您使用适用于 Apache Flink 的亚马逊托管服务中的 Apache Flink 应用程序来不断将 Kinesis Data Streams 捕获的日志数据转换并传送到 Amazon Simple Storage Service（Amazon S3）。使用多个运算符转换日志数据，包括将模式应用于不同的日志事件，按事件类型对数据进行分区，按时间戳对数据进行排序，以及在交付前缓冲数据一小时。该应用程序有许多转换步骤，但没有一个是计算密集型的。这种流每天 12 小时以每秒 2000 条记录的速度摄取数据，并增加至每天 12 小时以每秒 8000 条记录的速度摄取数据。您不创建任何持久应用程序备份。适用于 Apache Flink 的亚马逊托管服务的月度费用将按以下方式计算：
月度费用
美国东部（弗吉尼亚北部）区域的价格为每 KPU 每小时 0.11 USD。适用于 Apache Flink 的亚马逊托管服务为每个 KPU 分配 50GB 的运行应用程序存储空间，并按每月每 GB 0.10 美元的费率收费。
繁重工作负载：在 12 小时的繁重工作负载期间，适用于 Apache Flink 的亚马逊托管服务应用程序每秒处理 8000 条记录，并自动纵向扩展到 8 个 KPU。在繁重工作负载期后，适用于 Apache Flink 的亚马逊托管服务应用程序在吞吐量降低 6 小时后会缩小应用程序的规模。应用程序纵向扩展到 8 个 KPU，每天总计 18 小时。
30 天/月 * 18 小时/天 = 540 小时/月
每月 KPU 费用 = 540 小时/月 * 8 KPU * 0.11 USD/小时 = 475.20 USD
每月运行应用程序存储费用 = 540 小时/月 * 8 KPU * 50GB/KPU * 0.10 USD/GB-月 = 30.00 USD
每月 KPU 和存储费用 = 475.20 USD + 30.00 USD = 505.20 USD
轻量工作负载：在余下 6 小时的轻量工作负载期间，适用于 Apache Flink 的亚马逊托管服务应用程序每秒处理 2000 条记录，并自动缩减到 2 个 KPU。
30 天/月 * 6 小时/天 = 180 小时/月
每月 KPU 费用 = 180 小时/月 * 2 KPU * 0.11 USD/小时 = 39.60 USD
每月运行应用程序存储费用 = 180 小时/月 * 2 KPU * 50GB * 0.10 USD/GB-月 = 2.50 USD
每月 KPU 和存储费用 = 39.60 USD + 2.50 USD = 42.10 USD
对 Apache Flink 应用程序，每应用程序收取一个额外的 KPU 费用。
额外 KPU 的月度费用 = 30 * 24 * 1 个 KPU * 0.11 USD/小时 = 79.20 USD
总费用 = 505.20 USD + 42.10 USD + 79.20 USD = 626.50 USD
您可以使用适用于 Apache Flink 的亚马逊托管服务中的 Apache Flink 应用程序，以批处理模式转换 Amazon Simple Storage Service（Amazon S3）中的日志数据。使用多个运算符转换日志数据，例如将模式应用于不同的日志事件、按事件类型对数据进行分区以及按时间戳对数据进行排序。该应用程序有许多转换步骤，但没有一个是计算密集型的。该应用程序在一个月（30 天）内以每秒 2000 条记录的速度摄取数据，每天持续 10 分钟。您不创建任何持久应用程序备份。适用于 Apache Flink 的亚马逊托管服务的月度费用将按以下方式计算：
月度费用
美国东部（弗吉尼亚北部）区域的价格为每 KPU 每小时 0.11 USD。适用于 Apache Flink 的亚马逊托管服务为每个 KPU 分配 50GB 的运行应用程序存储空间，并按每月每 GB 0.10 美元的费率收费。
批处理工作负载：每天 10 分钟，适用于 Apache Flink 的亚马逊托管服务应用程序每秒处理 2000 条记录，需要 2 个 KPU。
30 天/月 * 10 分钟/天 = 300 分钟/月
每月 KPU 费用 = 300 分钟/月 * 2 个 KPU * 0.11USD/小时 = 1.10 USD
每月运行应用程序存储费用 = 300 分钟/月 * 2 个 KPU * 50GB * 0.10 USD/GB-月 = 0.07 USD
每月 KPU 和存储费用 = 1.10 USD + 0.07 USD = 1.17 USD
对 Apache Flink 应用程序，每应用程序收取一个额外的 KPU 费用。
每月费用 = 1 个 KPU * 0.11 USD/小时 * 10 分钟/月 = 0.02 USD（四舍五入到最接近的美分）
总费用 = 1.17 USD + 0.02 USD = 1.19 USD
您使用适用于 Apache Flink Studio 的亚马逊托管服务持续筛选 Amazon Kinesis Data Streams 捕获的流式传输数据，并仅保留感兴趣的记录。您希望能够实时查看记录并予以可视化处理，并且能够以 SQL 和 Python 轻松编写查询和程序。您不需要持久性状态备份。根据输入流的吞吐量，您为自己的 Studio 笔记本预置了 4 个 KPU。适用于 Apache Flink 的亚马逊托管服务的月度费用将按以下方式计算：
月度费用
美国东部（弗吉尼亚北部）区域用于流处理应用程序的价格为每 KPU 每小时 0.11 USD。这个简单的应用程序使用 4 KPU 来处理传入的数据流。每个 Studio 笔记本应用程序（例如：交互式模式）需要为每个应用程序的 2 个额外 KPU 付费。
每月 KPU 费用 = 30 天 * 24 小时 *（4 KPU + 2 个 用于 Studio 笔记本的额外 KPU）* 0.11 USD/小时）= 475.20 USD
Apache Flink 应用程序每个 KPU 使用 50GB 的运行应用程序存储，另外为 Studio 笔记本应用程序使用 50GB 的运行存储，在 US-East-1 区域，每 GB/月收费 0.10 USD。
每月运行应用程序存储费用 = 30 天 * 24 小时 *（4 个 KPU + 1 个用于 Studio 笔记本的额外 KPU）*（50GB * 0.10 USD/GB-月）= 25.00 USD
总费用 = 475.20 USD + 25.00 USD = 500.20 USD
您使用适用于 Apache Flink Studio 的亚马逊托管服务在您的 Amazon Managed Streaming for Apache Kafka（Amazon MSK）集群中的主题捕获的流式传输数据上构建滑动窗口。您使用具有 4 个 KPU 的 Studio 笔记本，在每月第一天的 10:30 开始启用该笔记本，以开发和测试您的查询。完成开发后，您在 17:00 将应用程序部署为带有 2 个 KPU 的流式传输应用程序。完成流式传输应用程序的部署后，您在 18:00 停用了 Studio 笔记本。流式传输应用程序可以使用持久的应用程序状态，您可以每天创建持久的状态备份。
美国东部（弗吉尼亚北部）区域用于流处理应用程序的价格为每 KPU 每小时 0.11 USD。
月度费用
使用适用于 Apache Flink Studio 的亚马逊托管服务开发和测试查询：
您的 Studio 应用程序当月运行 450 分钟（第一天 10:30 至 18:00）
KPU 费用 = 450 分钟 *（4 个 KPU + 2 个用于 Studio 笔记本的额外 KPU）* 0.11 USD/小时）= 4.95 USD
Apache Flink 应用程序每个 KPU 使用 50GB 的运行应用程序存储，另外为 Studio 笔记本应用程序使用 50GB 的运行存储，在 US-East-1 区域，每 GB/月收费 0.10 USD。
运行应用程序存储费用 = 450 分钟 *（4 个 KPU + 1 个用于 Studio 笔记本的额外 KPU）*（50GB * 0.10 USD/GB-月）= 0.26 USD
部署为流式传输应用程序以持续运行并执行应用程序备份：
流式传输应用程序当月运行 703 小时（从第一天 17:00 开始）
KPU 费用 = 703 小时 *（2 个 KPU + 1 个用于流式传输应用程序的额外 KPU）* 0.11 USD/小时）= 231.99 USD
Apache Flink 应用程序每 KPU 使用 50GB 运行应用程序存储，在 US-East-1 每月每 GB 收费 0.121 USD。
运行应用程序存储费用 = 703 小时 * 2 个 KPU *（50GB * 0.10 USD/GB-月）= 9.76 USD
持久应用程序存储费用 = 703 小时 *（1MB/备份 * 1GB/1000MB）* 0.023 USD/GB-月 = 0.01 USD（四舍五入到最近的美分）
总费用 = 4.95 USD + 0.26 USD + 231.99 USD + 9.76 USD + 0.01 USD = 246.97 USD