Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。
本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
开始使用适用于 Python 的 Apache Flink 的亚马逊托管服务
本节向您介绍使用 Python 和表 API 的 Managed Service for Apache Flink的基本概念。它介绍了可用于创建和测试应用程序的选项。它还提供了相应的说明以安装所需的工具,以完成本指南中的教程和创建第一个应用程序。
主题
Pyflink 入门 — 适用于 Apache 的 Python 解释器 | Amazon Web Services
在开始之前,我们建议您首先观看以下视频:
适用于 Apache Flink 应用程序的托管服务的组件
为了处理数据,Managed Service for Apache Flink 应用程序使用 Python 应用程序,其使用 Apache Flink 运行时系统处理输入和生成输出。
Managed Service for Apache Flink 应用程序包含以下组件:
在创建并打包应用程序代码后,将代码包上传到 Amazon S3 存储桶。然后,您创建一个 Managed Service for Apache Flink 应用程序。您传入代码包位置、流数据源以及通常接收应用程序处理的数据的流或文件位置。
先决条件
在开始本教程之前,请先完成 开始使用适用于 Apache Flink 的亚马逊托管服务 (DataStreamAPI)中的前两个步骤:
要开始使用,请参阅 创建应用程序。