要开始使用 Amazon Kinesis Data Analytics,最好的方式是通过构建示例应用程序获得实践经验。只需前往 Amazon Kinesis Data Analytics 控制台,然后创建一个新的 Amazon Kinesis Data Analytics 应用程序即可。请根据您选择的应用程序是基于 Apache Flink 还是 SQL 执行以下步骤:

首先,创建一个连续读取和处理流数据的 Kinesis Data Analytics 应用程序。使用您喜欢的 IDE 下载开源 Apache Flink 库,然后编写应用程序代码并使用实时流数据进行测试。您可以配置希望接收 Kinesis Data Analytics 发送的结果的目的地。

您可以参阅《Amazon Kinesis Data Analytics for Apache Flink 开发人员指南》,了解如何下载库并创建您的首个应用程序。阅读在 Amazon Kinesis Data Analytics 上使用的 Apache Flink 版本的官方 Apache Flink 文档,查找 Apache Flink 支持的其他语言的等效代码。

第 1 步:将开源库下载到您喜欢的 IDE

创建 Java 应用程序

首先下载开源库,包括 AWS 开发工具包、Apache Flink 和 AWS 服务连接器。 

Java 示例代码

使用数据流和流运算符编写 Apache Flink 应用程序代码。应用程序数据流是您使用应用程序代码执行处理所依据的数据结构。数据不断地从源流向应用程序数据流。一个或多个流运算符用于定义对应用程序数据流的处理。

第 3 步:将代码上传至 Kinesis Data Analytics

配置 Java 应用程序

构建完成之后,将代码上传至 Amazon Kinesis Data Analytics,该服务会处理持续运行实时应用程序所需的任何事项,包括自动扩展以匹配传入数据的大小和吞吐量。

“开发人员指南”中的 Amazon Kinesis Data Analytics for Apache Flink 应用程序入门部分介绍了构建首个应用程序的简单步骤。

使用预构建的解决方案快速入门

使用适用于 Amazon Kinesis 的 AWS 流数据解决方案帮助您解决实时流使用案例,例如捕获大量应用程序日志、分析点击流数据、持续交付到数据湖等。

15 分钟培训视频说明了如何在 Amazon Kinesis Data Analytics 中使用 Apache Flink 应用程序,以便从数据中获得更及时的见解。

SQL 非常容易上手

首先,创建一个新的 Amazon Kinesis Data Analytics 应用程序。选择我们作为输入内容提供的演示流,选取模板,然后编辑 SQL 查询。然后,您可以直接在控制台中查看结果,也可以将输出内容加载到 Amazon Elasticsearch Service 中使用 Kibana 查看。您能够在几分钟内部署一个完整的流数据应用程序。

第 1 步:配置输入流

配置输入流

首先,转至 Amazon Kinesis Data Analytics 控制台,然后选择 Kinesis 数据流或 Kinesis Data Firehose 交付流作为输入流。Amazon Kinesis Data Analytics 会提取数据、自动识别标准数据格式并提供一个建议架构。您可以对此架构进行优化,或者如果输入数据为非结构化数据,则可以使用我们的直观架构编辑器定义新的架构。

阅读文档 

第 2 步:编写 SQL 查询

编写 SQL 查询

接下来,编写 SQL 查询以使用 Amazon Kinesis Data Analytics SQL 编辑器和内置模板处理流数据,然后使用实时流数据进行测试。

阅读文档 

第 3 步:配置输出流

配置输出流

最后,指出希望加载结果的目标位置。Amazon Kinesis Data Analytics 集成了开箱即用的 Amazon Kinesis Data Streams 和 Amazon Kinesis Data Firehose,这样可以将处理的结果轻松发送至 Amazon S3、Amazon Redshift、Amazon Elasticsearch Service 或您自己的自定义目标。

阅读文档 

入门示例

这些资源提供了流数据应用程序示例和分步说明,因此您可以试用并获得实践经验。

工作原理

SQL 开发人员指南概括介绍了 Amazon Kinesis Data Analytics 的架构、如何创建应用程序以及如何配置输入和输出。

入门

入门指南中,我们逐步为您介绍了 AWS 账户的设置、命令行界面 (AWS CLI) 以及如何创建第一个 Amazon Kinesis Data Analytics 应用程序。

示例应用程序

示例应用程序指南提供了代码示例和分步说明,可以帮助您创建 Amazon Kinesis Data Analytics 应用程序并测试结果。

操作说明视频

Kinesis Data Analytics 入门非常简单。操作说明视频从技术层面详细介绍了常见使用案例和流式处理工作流程,因此使其变得更加简单。这些视频还深入概述了相关重要功能,以便您能顺利完成任务。单击以下链接观看录像:

Amazon Kinesis Data Analytics 简介 (2:21)
源实时控制面板 (3:14)
创建实时警报 (2:59)
生成时间序列分析 (2:32)

Amazon Kinesis Data Analytics 入门

注册 AWS 账户
注册 AWS 账户

立即享受 AWS 免费套餐

查看入门指南
查看入门指南

通过分步指南了解如何使用 Amazon Kinesis Data Analytics for SQL 或 Amazon Kinesis Data Analytics for Apache Flink

开始在控制台中构建
开始构建流式处理应用程序

从 Amazon Kinesis Data Analytics 控制台构建流应用程序。