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.4 (opcional): actualizar el código de la aplicación
En este paso, explore cómo actualizar el código de la aplicación.
Para actualizar el código de la aplicación
-
Cree otra secuencia en la aplicación del siguiente modo:
-
Cree otra secuencia en la aplicación llamada
DESTINATION_SQL_STREAM_2
. -
Cree una bomba y luego utilícela para insertar filas en la secuencia recién creada seleccionando filas de
DESTINATION_SQL_STREAM
.
En el SQL editor, añada el siguiente código al código de la aplicación existente:
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS INSERT INTO "DESTINATION_SQL_STREAM_2" SELECT STREAM ticker_symbol, change, price FROM "DESTINATION_SQL_STREAM";
Guarde y ejecute el código. Otros flujos en la aplicación aparecerán en la pestaña Real-time analytics.
-
-
Cree dos secuencias en la aplicación. Filtre las filas de
SOURCE_SQL_STREAM_001
basándose en el símbolo de la cotización y luego insértelas en estas secuencias independientes.Añada las siguientes SQL instrucciones al código de la aplicación:
CREATE OR REPLACE STREAM "AMZN_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "AMZN_PUMP" AS INSERT INTO "AMZN_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%AMZN%'; CREATE OR REPLACE STREAM "TGT_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "TGT_PUMP" AS INSERT INTO "TGT_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%TGT%';
Guarde y ejecute el código. Tenga en cuenta las secuencias en la aplicación adicionales en la pestaña Real-time analytics.
Ya tiene la primera aplicación de análisis de datos de Amazon Kinesis Data Analytics en funcionamiento. En este ejercicio ha hecho lo siguiente:
-
Ha creado su primera aplicación de análisis de datos de Kinesis Data Analytics.
-
Ha configurado la entrada de la aplicación que identificaba la secuencia de demostración como el origen de streaming y se la ha asignado a una secuencia en la aplicación (
SOURCE_SQL_STREAM_001
) que se crea. Kinesis Data Analytics lee de manera continua la secuencia de demostración e introduce los registros en la secuencia en la aplicación. -
El código de la aplicación solicitó el
SOURCE_SQL_STREAM_001
y escribió la salida en otra secuencia en la aplicación denominadaDESTINATION_SQL_STREAM
.
Ahora tiene la opción de configurar la salida de la aplicación a fin de escribir la salida de la aplicación en un destino externo. Es decir, puede configurar la salida de la aplicación para escribir registros de DESTINATION_SQL_STREAM
en un destino externo. Para este ejercicio, este paso es opcional. Para obtener información sobre cómo configurar el destino, vaya al siguiente paso.
Paso siguiente
Paso 4 (opcional) Edite el esquema y el SQL código mediante la consola.