Ejemplo: Creación de alertas simples - Guía para desarrolladores de aplicaciones de Amazon Kinesis Data Analytics para SQL

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

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

2. Eliminaremos sus aplicaciones a partir del 27 de enero de 2026. No podrá iniciar ni utilizar sus aplicaciones de Amazon Kinesis Data Analytics para SQL. A partir de ese momento, el servicio de soporte de Amazon Kinesis Data Analytics para SQL dejará de estar disponible. Para obtener más información, consulte Retirada de las aplicaciones de Amazon Kinesis Data Analytics para SQL.

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.

Ejemplo: Creación de alertas simples

En esta aplicación de Kinesis Data Analytics, la consulta se ejecuta de forma continua en la secuencia en la aplicación creada sobre la secuencia de demostración. Para obtener más información, consulte Consultas continuas.

Si hay filas cuya cotización cambia más del 1 por ciento, dichas filas se insertan en otra secuencia en la aplicación. En el ejercicio, puede configurar la salida de la aplicación para conservar los resultados en un destino externo. A continuación, puede continuar investigando los resultados. Por ejemplo, puede usar una AWS Lambda función para procesar registros y enviarle alertas.

Para crear una aplicación con alertas simples

  1. Cree una aplicación de Kinesis Data Analytics, tal y como se describe en el ejercicio de Introducción de Kinesis Data Analytics.

  2. En el editor de SQL de Kinesis Data Analytics, sustituya el código de la aplicación por el siguiente: 

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
           (ticker_symbol VARCHAR(4), 
            sector        VARCHAR(12), 
            change        DOUBLE, 
            price         DOUBLE);

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  (ABS(Change / (Price - Change)) * 100) > 1;

    La instrucción SELECT del código de la aplicación filtra las filas de SOURCE_SQL_STREAM_001 para seleccionar aquellas en las que los cambios en las cotizaciones de los valores sean superiores al 1 por ciento. A continuación, inserta esas filas en otra secuencia en la aplicación DESTINATION_SQL_STREAM mediante una bomba. Para obtener más información sobre el patrón de codificación que explica la utilización de bombas para insertar filas en las secuencias en la aplicación, consulte Código de la aplicación.

  3. Elija Save and run SQL.

  4. Añada un destino. Para ello, elija la pestaña Destination (Destino) en el editor de SQL o Add a destination (Añadir un destino) en la página de detalles de la aplicación.

    1. En el editor de SQL, elija la pestaña Destination (Destino) y, a continuación, elija Connect to a destination (Conectarse a un destino).

      En la página Connect to destination (Conectarse a un destino), elija Create New (Crear uno nuevo).

    2. Elija Go to Kinesis Streams.

    3. En la consola de Amazon Kinesis Data Streams, cree una nueva secuencia de Kinesis (por ejemplo, gs-destination) con una partición. Espere hasta que el estado de secuencia sea ACTIVE

    4. Vuelva a la consola de Kinesis Data Analytics. En la página Connect to destination (Conectarse a un destino), elija la secuencia que ha creado.

      Si la secuencia no aparece, actualice la página.

    5. Elija Guardar y continuar.

    Ahora tiene un destino externo, un flujo de datos de Kinesis donde Kinesis Data Analytics conserva la salida de la aplicación en la secuencia en la aplicación DESTINATION_SQL_STREAM.

  5. Configure AWS Lambda para supervisar la transmisión de Kinesis que ha creado e invocar una función Lambda.

    Para obtener instrucciones, consulte Procesamiento previo de registros con una función de Lambda.