Paso 2: Creación de una aplicación de Kinesis Data Analytics

En esta sección del ejemplo de puntos de acceso, crea una aplicación de análisis de datos de Kinesis Data Analytics tal como se indica a continuación:

• Configure la entrada de la aplicación para que utilice la secuencia de datos de Kinesis que ha creado como origen de streaming en el paso 1.

• Utilice el código de la aplicación proporcionado en la AWS Management Console.

Para crear una aplicación

1. Cree una aplicación de análisis de datos de Kinesis Data Analytics; para ello, siga los pasos 1, 2 y 3 del ejercicio de introducción (consulte Paso 3.1: Cree una aplicación).

   En la configuración fuente, haga lo siguiente:

   • Especifique el origen de streaming que creó en Paso 1: Crear las secuencias de entrada y de salida.

   • Después de que la consola deduzca el esquema, edítelo. Asegúrese de que los tipos de columna x e y estén establecidos en DOUBLE y que el tipo de columna IS_HOT esté establecido en VARCHAR.

2. Utilice el siguiente código de la aplicación (puede pegar este código en el editor de SQL):

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
       "x" DOUBLE, 
       "y" DOUBLE, 
       "is_hot" VARCHAR(4),
       HOTSPOTS_RESULT VARCHAR(10000)
   ); 
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
       INSERT INTO "DESTINATION_SQL_STREAM" 
       SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" 
       FROM TABLE (
           HOTSPOTS(   
               CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 
               1000, 
               0.2, 
               17)
       );
   

3. Ejecute el código SQL y revise los resultados.

   

Paso siguiente

Paso 3: Configurar la salida de la aplicación