经过仔细考虑，我们决定停用适用于 SQL 应用程序的 Amazon Kinesis Data Analytics：

1. 从 **2025年9月1日起，**我们将不再为适用于SQL应用程序的Amazon Kinesis Data Analytics Data Analytics提供任何错误修复，因为鉴于即将停产，我们对其的支持将有限。

2. 从 **2025 年 10 月 15 日**起，您将无法为 SQL 应用程序创建新的 Kinesis Data Analytics。

3. 从 **2026 年 1 月 27 日**起，我们将删除您的应用程序。您将无法启动或操作 Amazon Kinesis Data Analytics for SQL 应用程序。从那时起，将不再提供对 Amazon Kinesis Data Analytics for SQL 的支持。有关更多信息，请参阅 [Amazon Kinesis Data Analytics for SQL 应用程序停用](discontinuation.md)。

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

# 示例：在 应用程序中添加引用数据
<a name="app-add-reference-data"></a>

在本练习中，您在现有 数据分析应用程序中添加引用数据。有关引用数据的信息，请参阅以下主题：
+ [Amazon Kinesis Data Analytics for SQL 应用程序：工作原理](how-it-works.md)
+ [配置应用程序输入](how-it-works-input.md)

在本练习中，您将引用数据添加到在 Kinesis Data Analytics [入门](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/get-started-exercise.html)练习中创建的应用程序。引用数据提供每个股票代号对应的公司名称；例如：

```
Ticker, Company
AMZN,Amazon
ASD, SomeCompanyA
MMB, SomeCompanyB
WAS,  SomeCompanyC
```

首先，请完成[入门](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/get-started-exercise.html)练习中的步骤，以创建一个启动应用程序。然后，执行以下步骤进行设置，并将引用数据添加到应用程序：

1. **准备数据**
   + 将上述参考数据作为对象存储在 Amazon Simple Storage Service (Amazon S3) 中
   + 创建 IAM 角色，Kinesis Data Analytics 可以担任该角色来代表您读取 Amazon S3 对象。

1. **将引用数据源添加到您的应用程序。**

   读取 对象，并创建应用程序内部引用表，您可以在应用程序代码中查询该表。

1. **测试代码。**

   在应用程序代码中，将编写一个联接查询来联接应用程序内部流和应用程序内部引用表，从而获取每个股票代码的对应公司名称。

**Topics**
+ [步骤 1：准备](#add-refdata-prepare)
+ [步骤 2：将引用数据源添加到应用程序配置中](#add-refdata-create-iamrole)
+ [步骤 3：测试：查询应用程序内部引用表](#add-refdata-test)

## 步骤 1：准备
<a name="add-refdata-prepare"></a>

在此部分中，您将示例引用数据作为对象存储在 存储桶中。您还将创建 IAM 角色，可担任该角色来代表您读取对象。

### 将引用数据存储为 Amazon S3 对象。
<a name="prepare-create-s3object"></a>

在这一步中，将示例引用数据存储为 Amazon S3 对象。

1. 打开文本编辑器，添加以下数据，然后将文件另存为 `TickerReference.csv`。

   ```
   Ticker, Company
   AMZN,Amazon
   ASD, SomeCompanyA
   MMB, SomeCompanyB
   WAS,  SomeCompanyC
   ```

   

1. 将 `TickerReference.csv` 文件上传到 S3 存储桶。有关说明，请参阅 *Amazon Simple Storage Service 用户指南*中的[上传对象](https://docs.aws.amazon.com/AmazonS3/latest/userguide/UploadingObjectsintoAmazonS3.html)。

### 创建 IAM 角色
<a name="prepare-create-iamrole"></a>

接下来，创建一个 Kinesis Data Analytics 可以代入的 IAM 角色并读取 Amazon S3 对象。

1. 在 AWS Identity and Access Management (IAM) 中，创建一个名为的 IAM 角色**KinesisAnalytics-ReadS3Object**。要创建该角色，请按照 [IAM 用户指南](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_roles_create_for-service.html#roles-creatingrole-service-console)中的*为 Amazon Web Service 创建角色（AWS 管理控制台）*中的说明操作。

   在 IAM 控制台上，指定以下项：
   + 再**选择角色类型**中，选择 **AWS Lambda**。创建角色后，您将更改信任策略以允许 Kinesis Data Analytics（ AWS Lambda不是）担任该角色。
   + 不要在 **Attach Policy** 页面上附加任何策略。

1. 更新 IAM 角色策略：

   

   1. 在 IAM 控制台上，选择您创建的角色。

   1. 在**信任关系**选项卡上，更新信任策略以便为 Kinesis Data Analytics 授予权限以代入该角色。下面显示了信任策略：

------
#### [ JSON ]

****  

      ```
      {
        "Version":"2012-10-17",		 	 	 
        "Statement": [
          {
            "Effect": "Allow",
            "Principal": {
              "Service": "kinesisanalytics.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
          }
        ]
      }
      ```

------

      

   1. **在 “**权限**” 选项卡上，附上名为 AmazonS3 的亚马逊管理的策略。ReadOnlyAccess**这会为该角色授予权限以读取 对象。下面显示了此策略：

------
#### [ JSON ]

****  

      ```
      {
        "Version":"2012-10-17",		 	 	 
        "Statement": [
          {
            "Effect": "Allow",
            "Action": [
              "s3:Get*",
              "s3:List*"
            ],
            "Resource": "*"
          }
        ]
      }
      ```

------

## 步骤 2：将引用数据源添加到应用程序配置中
<a name="add-refdata-create-iamrole"></a>

在该步骤中，将引用数据源添加到应用程序配置中。要开始操作，需要以下信息：
+ S3 存储桶名称和对象键名称
+ IAM 角色的 Amazon 资源名称 (ARN)

1. 在应用程序主页面中，选择 **Connect reference data (连接引用数据)**。

1. 在**连接引用数据来源**页面上，选择包含引用数据对象的 Amazon S3 存储桶，并输入对象的键名称。

1. 在**应用程序内部引用表名称**处输入 **CompanyName**。

1. 在**对所选资源的访问权限部分，选择****从 Kinesis Analytics 可以担任的 IAM 角色**中选择，然后选择您在上一节中创建的 **KinesisAnalytics-reads3Object** IAM 角色。

1. 选择 **发现架构**。控制台检测到引用数据中的两列。

1. 选择**保存并关闭**。

## 步骤 3：测试：查询应用程序内部引用表
<a name="add-refdata-test"></a>

现在，您可以查询应用程序内部引用表 `CompanyName`。您可以联接股票价格数据和引用表以使用引用信息扩充应用程序。结果显示公司名称。

1. 用以下内容替换您的应用程序代码。查询会联接应用程序内部输入流和应用程序内部引用表。应用程序代码将结果写入到另一应用程序内部流 `DESTINATION_SQL_STREAM`。

   ```
   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), "Company" varchar(20), sector VARCHAR(12), change DOUBLE, price DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
      SELECT STREAM ticker_symbol, "c"."Company", sector, change, price
      FROM "SOURCE_SQL_STREAM_001" LEFT JOIN "CompanyName" as "c"
      ON "SOURCE_SQL_STREAM_001".ticker_symbol = "c"."Ticker";
   ```

1. 验证应用程序输出是否出现在**SQLResults**选项卡中。确保某些行显示公司名称 (示例引用数据不包含所有公司名称)。