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

经过仔细考虑,我们决定分两个步骤停止使用亚马逊 Kinesis Data Analytics SQL 的应用程序:

1. 从 2025 年 10 月 15 日起,您将无法为应用程序创建新的 Kinesis Data Analytic SQL s。

2. 我们将从 2026 年 1 月 27 日起删除您的申请。您将无法启动或操作适用于应用程序的 Amazon Kinesis Data Analytic SQL s。从那时起,亚马逊 Kinesis Data Analytics SQL 将不再提供支持。有关更多信息,请参阅 适用于应用程序的 Amazon Kinesis Data Analytic SQL s 停产

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

步骤 3.4:(可选) 更新应用程序代码

在此步骤中,您将研究如何更新应用程序代码。

更新应用程序代码
  1. 按如下方式创建另一个应用程序内部流:

    • 创建名为 DESTINATION_SQL_STREAM_2 的另一个应用程序内部流。

    • 创建数据泵,然后从 DESTINATION_SQL_STREAM 中选择行,以便使用数据泵在新创建的流中插入这些行。

    在SQL编辑器中,将以下代码附加到现有应用程序代码中:

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS INSERT INTO "DESTINATION_SQL_STREAM_2" SELECT STREAM ticker_symbol, change, price FROM "DESTINATION_SQL_STREAM";

    保存并运行代码。Real-time analytics 选项卡上将显示其他应用程序内部流。

  2. 创建两个应用程序内部流。根据股票代码筛选 SOURCE_SQL_STREAM_001 中的行,然后将这些行插入到这些单独的流中。

    在应用程序代码中添加以下SQL语句:

    CREATE OR REPLACE STREAM "AMZN_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "AMZN_PUMP" AS INSERT INTO "AMZN_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%AMZN%'; CREATE OR REPLACE STREAM "TGT_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "TGT_PUMP" AS INSERT INTO "TGT_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%TGT%';

    保存并运行代码。请注意 Real-time analytics 选项卡上的其他应用程序内部流。

您现已创建第一个正常运行的 Amazon Kinesis Data Analytics 应用程序。在本练习中,您已完成以下操作:

  • 创建了第一个 Kinesis Data Analytics 应用程序。

     

  • 配置将演示流标识为流式源的应用程序输入,并将其映射到创建的应用程序内部流 (SOURCE_SQL_STREAM_001)。Kinesis Data Analytics 持续读取演示流,并在应用程序内部流中插入记录。

     

  • 应用程序代码已查询 SOURCE_SQL_STREAM_001,并将输出写入到名为 DESTINATION_SQL_STREAM 的另一个应用程序内部流。

现在,您可以选择性地配置应用程序输出,以便将应用程序输出写入到外部目标。也就是说,您可配置应用程序输出以便将 DESTINATION_SQL_STREAM 中的记录写入到外部目标。在本练习中,此步骤为可选步骤。要了解如何配置目标,请转到下一步。

下一个步骤

步骤 4(可选)使用控制台编辑架构和SQL代码.