Paso 3: crear la aplicación inicial de Amazon Kinesis Data Analytics

Mediante los pasos de esta sección, puede crear la primera aplicación de Kinesis Data Analytics utilizando la consola.

nota

Le recomendamos que consulte Aplicaciones de Amazon Kinesis Data Analytics para SQL: cómo funciona antes de probar el ejercicio de introducción.

En este ejercicio de introducción, puede utilizar la consola para trabajar con la secuencia de demostración o las plantillas con el código de la aplicación.

• Si decide utilizar la secuencia de demostración, la consola crea un flujo de datos de Kinesis en su cuenta denominada kinesis-analytics-demo-stream.

  Una aplicación de Kinesis Data Analytics requiere un origen de streaming. Para esta origen, varios ejemplos de SQL de esta guía utilizar la secuencia de demostración kinesis-analytics-demo-stream. La consola también ejecuta un script que añade continuamente datos de muestra (registros de operaciones bursátiles simuladas) a esta secuencia, tal y como se muestra a continuación.

  

  Puede utilizar kinesis-analytics-demo-stream como el origen de streaming para su aplicación en este ejercicio.

  nota

  La secuencia de demostración permanece en su cuenta. Puede utilizarla para probar otros ejemplos que aparecen en esta guía. Sin embargo, cuando salga de la consola, el script que utiliza la consola dejará de rellenar los datos. Cuando sea necesario, la consola proporcionará la opción de comenzar a rellenar la secuencia nuevamente.

• Si decide usar las plantillas con ejemplo de código de la aplicación, puede utilizar el código de plantilla que proporciona la consola para realizar análisis sencillos en la secuencia de demostración.

Puede utilizar estas características para configurar de manera rápida su primera aplicación de la siguiente manera:

1. Crear una aplicación: solo tiene que proporcionar un nombre. La consola crea la aplicación y el servicio establece el estado de la aplicación en READY.

    

2. Configurar la entrada: en primer lugar, debe añadir un origen de streaming, la secuencia de demostración. Debe crear una secuencia de demostración en la consola antes de poder utilizarla. A continuación, la consola toma una muestra al azar de los registros de la secuencia de demostración e infiere un esquema para la secuencia de entrada en la aplicación que se crea. Los consola asigna el nombre SOURCE_SQL_STREAM_001 a la secuencia en la aplicación.

   La consola utiliza la API de detección para inferir el esquema. Si es necesario, puede editar el esquema inferido. Para obtener más información, consulte DiscoverInputSchema. Kinesis Data Analytics utiliza este esquema para crear una secuencia en la aplicación.

    

   Cuando se inicia la aplicación, Kinesis Data Analytics lee la secuencia de demostración de forma continua e introduce filas en la secuencia de entrada en la aplicación SOURCE_SQL_STREAM_001.

    

3. Especificar el código de la aplicación: puede utilizar una plantilla (llamada Continuous filter) que proporciona el siguiente código:

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
     (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
    
   -- Create pump to insert into output. 
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
      INSERT INTO "DESTINATION_SQL_STREAM"  
         SELECT STREAM ticker_symbol, sector, CHANGE, price
         FROM "SOURCE_SQL_STREAM_001"
         WHERE sector SIMILAR TO '%TECH%';

   El código de la aplicación consulta la secuencia en la aplicación SOURCE_SQL_STREAM_001. El código inserta las filas resultantes en otra secuencia en la aplicación (DESTINATION_SQL_STREAM), utilizando bombas. Para obtener más información sobre este patrón de codificación, consulte Código de la aplicación.

   Para obtener información sobre los elementos del lenguaje SQL compatibles con Kinesis Data Analytics, consulte Referencia de SQL de Amazon Kinesis Data Analytics.

    

4. Configurar la salida: en este ejercicio, no va a configurar salidas. Es decir, no va a preservar los datos en la secuencia en la aplicación que ha creado su aplicación en un destino externo. Lo que va a hacer es verificar los resultados de consulta en la consola. Existen más ejemplos en esta guía que ilustran de qué manera configurar la salida. Para ver un ejemplo, consulte Ejemplo: Creación de alertas simples.

importante

El ejercicio utiliza la Región Este de EE. UU. (Norte de Virginia) para configurar la aplicación. Puede utilizar cualquiera de los compatibles Regiones de AWS.

Paso siguiente

Paso 3.1: Cree una aplicación