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

Tras considerarlo detenidamente, hemos decidido interrumpir Amazon Kinesis Data Analytics SQL para aplicaciones en dos pasos:

1. A partir del 15 de octubre de 2025, no podrá crear nuevos Kinesis Data Analytics SQL para aplicaciones.

2. Eliminaremos sus aplicaciones a partir del 27 de enero de 2026. No podrá iniciar ni utilizar Amazon Kinesis Data Analytics SQL para aplicaciones. A partir de ese momento, el soporte para Amazon Kinesis Data Analytics dejará SQL de estar disponible. Para obtener más información, consulte Suspensión de Amazon Kinesis Data Analytics SQL for 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: 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 fuente, varios SQL ejemplos de esta guía utilizan la transmisión kinesis-analytics-demo-stream de demostración. 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. 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 el descubrimiento API para deducir 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 de SQL lenguaje compatibles con Kinesis Data Analytics, consulte la referencia de Amazon Kinesis Data Analytics. SQL

     

  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