Ejemplo: Agregar datos de referencia a una aplicación de Kinesis Data Analytics

Abra un editor de texto, añada los siguientes datos y guarde el archivo como TickerReference.csv.

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

Cargue el archivo TickerReference.csv en el bucket de S3. Para ver las instrucciones, consulte Carga de objetos en Amazon S3 en la Guía del usuario de Amazon Simple Storage Service.

En AWS Identity and Access Management (IAM), cree un rol de IAM denominado KinesisAnalytics-ReadS3Object. Para crear el rol, siga las instrucciones que se describen en Creación de un rol para un servicio de Amazon (AWS Management Console) en la Guía del usuario de IAM.

En la consola de IAM, especifique lo siguiente:

Actualice las políticas de roles de IAM:

1. En la consola de IAM, elija el rol que ha creado.

2. En la pestaña Relaciones de confianza, actualice la política de confianza para conceder permisos a Kinesis Data Analytics para asumir el rol. La política de confianza se muestra tras:

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

3. En la pestaña Premisos, asigne una política administrada de Amazon denominada AmazonS3ReadOnlyAccess. Esto concede permisos al rol para leer un objeto de Amazon S3. Esta política se muestra a continuación:

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

En página principal de la aplicación, elija Connect reference data (Conectar datos de referencia).

En la página Conectar el origen de datos de referencia, elija el bucket de Amazon S3 que contiene el objeto de datos de referencia y escriba el nombre de la clave del objeto.

Escriba CompanyName como In-application reference table name (Nombre de tabla de referencia en la aplicación).

En la sección Access to chosen resources (Obtener acceso a los recursos seleccionados), seleccione Choose from IAM roles that Kinesis Analytics can assume (Elegir entre las funciones de IAM que Kinesis Analytics puede asumir) y elija la función de IAM KinesisAnalytics-ReadS3Object que creó en la sección anterior.

Elija Discover schema (Detectar esquema). La consola detecta dos columnas en los datos de referencia.

Elija Save and close.

Reemplace el código de la aplicación por lo siguiente. La consulta une la secuencia de entrada en la aplicación con la tabla de referencia en la aplicación. El código de la aplicación escribe los resultados en otra secuencia en la aplicación, 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";

Compruebe que la salida de la aplicación aparezca en la pestaña SQLResults. Asegúrese de que algunas de las filas muestren nombres de empresas (no todos los datos de referencia de muestra tienen nombres de empresas).