适用于 Apache Flink 的亚马逊托管服务入门
为什么选择适用于 Apache Flink 的亚马逊托管服务？
借助适用于 Apache Flink 的亚马逊托管服务，您可以使用 Apache Flink 实时转换和分析串流数据。适用于 Apache Flink 的亚马逊托管服务简化了构建和管理 Apache Flink 工作负载的过程，并且使您可以将应用程序与其他 AWS 服务集成。
使用 Apache Flink 和 Apache Beam 构建串流应用程序
1
第 1 步：将开源库下载到您喜欢的 IDE
首先下载开源库，包括 AWS SDK、Apache Flink 和 AWS 服务连接器。
2
第 2 步：使用 Apache Flink 或 Apache Beam 构建示例应用程序
使用数据流和流运算符编写 Apache Flink 应用程序代码。应用程序数据流是您使用应用程序代码执行处理所依据的数据结构。数据不断地从源流向应用程序数据流。一个或多个流运算符用于定义对应用程序数据流的处理。
3
第 3 步：将您的代码上传到适用于 Apache Flink 的亚马逊托管服务
构建完成后，将您的代码上传到适用于 Apache Flink 的亚马逊托管服务。该服务会处理持续运行实时应用程序所需的任何事项，包括自动扩展以匹配传入数据的大小和吞吐量。
直观地使用适用于 Apache Flink Studio 的亚马逊托管服务
1
第 1 步：创建适用于 Apache Flink Studio 应用程序的亚马逊托管服务
从适用于 Apache Flink 的亚马逊托管服务、亚马逊 MSK 或 Amazon Kinesis Data Streams 控制台开始。使用自定义连接器来连接任何其他数据来源。
2
第 2 步：以 SQL、Python 和 Scala 在无服务器笔记本中编写代码，并开发 Apache Flink 应用程序
在笔记中运行单个段落，在上下文中查看结果，并使用 Apache Zeppelin 内置的可视化功能加速开发。您还可以在代码中使用用户定义的函数。
3
步骤 3：作为适用于 Apache Flink 的亚马逊托管服务串流应用程序进行构建和部署
将代码作为持续运行的流应用程序进行部署，只需几个步骤即可完成。您部署的应用程序将成为适用于 Apache Flink 的亚马逊托管服务应用程序，带有持久状态和自动扩缩功能。在将代码产品化之前，您还能更改源、目标位置、日志记录和监控层级。