Exemplo: adição de dados de referência a um aplicativo do Kinesis Data Analytics

Abra um editor de texto, adicione os seguintes dados e salve o arquivo como TickerReference.csv.

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

Faça upload do arquivo TickerReference.csv no bucket do S3. Para obter mais informações, consulte Fazer upload de objetos no Amazon S3 no Manual do usuário do Amazon Simple Storage Service.

Em AWS Identity and Access Management (IAM), crie um perfil do IAM chamado KinesisAnalytics-ReadS3Object. Para criar o perfil, siga as instruções em Criação de um perfil para um serviço da Amazon (AWS Management Console) no Guia do usuário do IAM.

No console do IAM, especifique o seguinte:

Atualize as políticas de perfil do IAM:

1. No console do IAM, selecione o perfil criado.

2. Na guia Relações de confiança, atualize a política de confiança para conceder ao Kinesis Data Analytics permissões para assumir a função. A política de confiança é mostrada a seguir:

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

3. Na guia Permissões, anexe uma política gerenciada pela Amazon chamada AmazonS3ReadOnlyAccess. Isso concede ao perfil permissões para ler um objeto do Amazon S3. Esta política é mostrada a seguir:

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

Na página principal do aplicativo, selecione Connect reference data (Conectar dados de referência).

Na página Conectar fonte de dados de referência, selecione o bucket do Amazon S3 que contém seu objeto de dados de referência e insira o nome da chave do objeto.

Insira CompanyName em In-application reference table name (Nome da tabela de referência no aplicativo).

Na seção Access to chosen resources (Acesso aos recursos escolhidos), selecione Choose from IAM roles that Kinesis Analytics can assume (Selecionar funções do IAM que o Kinesis Analytics possa assumir) e selecione a função do IAM KinesisAnalytics-ReadS3Object que você criou na seção anterior.

Escolha Discover schema (Descobrir esquema). O console detectará duas colunas nos dados de referência.

Escolha Save and close.

Substitua o código do aplicativo pelo seguinte. A consulta faz a junção do fluxo de entrada de aplicativo com a tabela de referência de aplicativo. O código do aplicativo grava os resultados em outro fluxo no aplicativo, 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";

Verifique se a saída do aplicativo aparece na guia SQLResults. Verifique se algumas linhas mostram nomes de empresa (os dados de referência de exemplo não têm todos os nomes de empresa).