Para proyectos nuevos, le recomendamos que utilice el nuevo servicio gestionado para Apache Flink Studio en lugar de aplicaciones de Kinesis Data Analytics para SQL. El servicio gestionado para Apache Flink Studio combina la facilidad de uso con capacidades analíticas avanzadas, lo que le permite crear aplicaciones sofisticadas de procesamiento de flujos en cuestión de minutos.
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.
Código de la aplicación
El código de la aplicación es una serie de instrucciones SQL que procesan entradas y generan salidas. Estas instrucciones SQL operan con secuencias en la aplicación y con tablas de referencia. Para obtener más información, consulte Aplicaciones de Amazon Kinesis Data Analytics para SQL: cómo funciona.
Para obtener información sobre los elementos del lenguaje SQL compatibles con Kinesis Data Analytics, consulte Referencia de SQL de Amazon Kinesis Data Analytics.
En bases de datos relacionales, se trabaja con tablas, utilizando instrucciones INSERT para añadir registros y la instrucción SELECT para consultar los datos. En Amazon Kinesis Data Analytics, trabaja con flujos. Puede escribir una instrucción SQL para consultar estas secuencias. Los resultados de la consulta de una secuencia en la aplicación siempre se envían a otra secuencia en la aplicación. Cuando realice análisis complejos, puede crear varias secuencias en la aplicación para guardar los resultados de los análisis intermedios. Por último, puede configurar la salida de la aplicación para que conserve los resultados del análisis final (de una o más secuencias en la aplicación) en destinos externos. A continuación se muestra un patrón típico para escribir código de la aplicación:
-
La instrucción SELECT siempre se utiliza en el contexto de una instrucción INSERT. Es decir, cuando selecciona filas, introduce resultados en otra secuencia en la aplicación.
-
La instrucción INSERT siempre se utiliza en el contexto de una bomba. Es decir, que utiliza bombas para escribir a una secuencia en la aplicación.
El siguiente ejemplo de aplicación el código lee los registros de una secuencia en la aplicación (SOURCE_SQL_STREAM_001) y la escribe en otra secuencia en la aplicación (DESTINATION_SQL_STREAM). Puede insertar registros en secuencias en la aplicación utilizando bombas, tal y como se muestra a continuación:
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); -- Create a pump and insert into output stream. CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, change,price FROM "SOURCE_SQL_STREAM_001";
nota
Los identificadores que especifique para los nombres de secuencia y de columna siguen las convenciones estándar de SQL. Por ejemplo, si pone comillas en torno a un identificador, el identificador distingue entre mayúsculas y minúsculas. Si no las pone, el identificador adoptará las mayúsculas de forma predeterminada. Para obtener más información sobre los identificadores, consulte identificadores en la referencia SQL de Amazon Managed Service para Apache Flink.
El código de la aplicación puede contener muchas instrucciones SQL. Por ejemplo:
-
Puede escribir consultas SQL de manera secuencial donde el resultado de una instrucción SQL alimenta la siguiente instrucción SQL.
-
También puede escribir consultas SQL que se ejecutan independientes entre sí. Por ejemplo, puede escribir dos instrucciones SQL que consulten la misma secuencia en la aplicación, pero enviar resultados en diferentes secuencias en la aplicación. A continuación, puede consultar las nuevas secuencias en la aplicación de manera independiente.
También puede crear secuencias en la aplicación para almacenar resultados de consultas intermedias. Puede insertar los datos en secuencias en la aplicación utilizando bombas. Para obtener más información, consulte Secuencias y bombeos en la aplicación.
Si añade una tabla de referencia en la aplicación, puede escribir SQL para unir los datos de las secuencias en la aplicación y las tablas de referencia. Para obtener más información, consulte Ejemplo: Agregar datos de referencia a una aplicación de Kinesis Data Analytics.
De acuerdo con la aplicación de la configuración de salida, Amazon Kinesis Data Analytics escribe datos de secuencias en la aplicación específicas a los destinos externos en función de la configuración de salida de la aplicación. Asegúrese de que el código de la aplicación escribe a las secuencias en la aplicación especificadas en la configuración de salida.
Para obtener más información, consulte los siguientes temas:
