Paso 3: Creación de la aplicación inicial de Amazon Kinesis Data Analytics - Guía para desarrolladores de Amazon Kinesis Data Analytics for SQL Applications

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Paso 3: Creación de 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 Data con la consola.

nota

Le recomendamos que consulte Amazon Kinesis Data Analytics para aplicaciones 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 una secuencia de datos de Kinesis en su cuenta denominadakinesis-analytics-demo-stream.

    Una aplicación de análisis de datos de Kinesis 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.

    
                        Tabla de muestra de secuencia con formato que contiene símbolos, sectores y cotizaciones bursátiles.

    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. Cree 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 una fuente 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 inicia la aplicación, Kinesis Data Analytics lee la secuencia de demostración de forma continua en su nombre e introduce filas en la pestañaSOURCE_SQL_STREAM_001en la aplicación.

     

  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, consulteReferencia SQL de Amazon Kinesis Data Analytics.

     

  4. Configuración de 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 EE. UU. Este (Norte de Virginia) (us-east-1) para configurar la aplicación. Puede usar cualquiera de las opciones admitidasRegiones de AWS.

Paso siguiente

Paso 3.1: Creación de una aplicación