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

如果我们为英文版本指南提供翻译,那么如果存在任何冲突,将以英文版本指南为准。在提供翻译时使用机器翻译。

步骤3.2: 配置输入

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

为应用程序添加流式传输源

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

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

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

       

      默认情况下,控制台命名应用程序内输入流的创建为 INPUT_SQL_STREAM_001。在此练习中,保持此名称显示。

       

      • 流参考名称 – 此选项显示创建的应用内输入流的名称, SOURCE_SQL_STREAM_001。您可以更改名称,但对于此练习,请保留此名称。

         

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

         

      • 使用AWSLambda记录预处理: 此选项是指定 AWS 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. 选择 Save and continue

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

下一步

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