步骤 3.2:配置输入 - 适用于 SQL 应用程序的 Amazon Kinesis Data Analytics 开发人员指南
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

对于新项目,建议您使用新的适用于 Apache Flink Studio 的托管服务,而不是使用适用于 SQL 应用程序的 Kinesis Data Analytics。Managed Service for Apache Flink Studio 不仅操作简单,还具有高级分析功能,使您能够在几分钟内构建复杂的流处理应用程序。

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

步骤 3.2:配置输入

您的应用程序需要流式传输源。控制台创建了演示流(名为 kinesis-analytics-demo-stream)以帮助您入门。控制台还会运行在流中填充记录的脚本。

为应用程序添加流式传输源
  1. 在控制台中的应用程序中心页面上,选择 Connect streaming data (连接流数据)

    
                            示例应用程序和“connect to a sourceGS (连接到 sourceGS)”按钮的屏幕截图。
  2. 在显示的页面上查看以下内容:

    • Source 部分,您可在其中指定应用程序的流式传输源。您可以选择现有流式传输源或创建流式传输源。在本练习中,您将新建一个流,即演示流。

       

      默认情况下,控制台将创建的应用程序内部输入流命名为 INPUT_SQL_STREAM_001。在本练习中,请按原样保留该名称。

       

      • Stream reference name - 此选项显示创建的应用程序内输入流的名称 SOURCE_SQL_STREAM_001。您可以更改此名称,但本练习将保留此名称。

         

        在输入配置中,您可以将演示流映射到创建的应用程序内部输入流。在启动应用程序时,Amazon Kinesis Data Analytics 持续读取演示流,并在应用程序内部输入流中插入行。您可以在应用程序代码中查询此应用程序内部输入流。

         

      • Record pre-processing with Amazon Lambda:(使用 预处理记录):您可以在此选项中指定一个 Amazon Lambda 表达式,以便在应用程序代码执行之前修改输入流中的记录。在此练习中,选中 Disabled 选项。有关 Lambda 预处理的更多信息,请参阅 使用 Lambda 函数预处理数据

    在本页上提供所有信息后,控制台会发送更新请求(请参阅UpdateApplication)以便将输入配置添加到应用程序。

  3. Source 页面上选择 Configure a new stream

  4. 选择 Create demo stream。控制台通过执行以下操作来配置应用程序输入:

    • 控制台创建一个名为 kinesis-analytics-demo-stream 的 Kinesis 数据流。

    • 控制台将使用示例股票行情机数据填充流。

    • 利用 DiscoverInputSchema 输入操作,控制台将通过读取流上的示例记录来推断架构。推断出的架构是适用于创建的应用程序内部输入流的架构。有关更多信息,请参阅 配置应用程序输入

    • 控制台将显示推断的架构和从流式传输源读取的用来推断架构的示例数据。

    控制台显示流式传输源中的示例记录。

    
                            “Formatted stream sample (格式化的流示例)”选项卡,以表格格式显示股票代号、部门和价格。

    以下内容将显示在 Stream sample 控制台页面上:

    • Raw stream sample 选项卡显示 DiscoverInputSchema API 操作为推断架构而采用的抽样原始流记录。

    • Formatted stream sample 选项卡显示 Raw stream sample 选项卡中的数据的表格式版本。

    • 如果您选择 Edit schema,则可以编辑推断的架构。在本练习中,请不要更改推断的架构。有关编辑架构的更多信息,请参阅使用架构编辑器

      如果您选择 Rediscover schema,则可以请求控制台再次运行 DiscoverInputSchema 并推断架构。

  5. 选择 保存并继续

    现在,您已具有一个已添加输入配置的应用程序。在下一步中,您将添加 SQL 代码以便对应用程序内部输入流中的数据执行一些分析。

下一个步骤

步骤 3.3:添加实时分析(添加应用程序代码)