Paso 3.3: Añadir análisis en tiempo real (añadir el código de la aplicación)

Puede escribir sus propias SQL consultas en función del flujo de la aplicación, pero para el siguiente paso utilizará una de las plantillas que proporcionan un código de ejemplo.

1. En la página del centro de aplicaciones, selecciona Ir al SQL editor.

   

2. En el cuadro ¿Desea empezar a ejecutar "ExampleApp«? cuadro de diálogo, seleccione Sí, iniciar la aplicación.

   La consola envía una solicitud para iniciar la aplicación (consulteStartApplication) y, a continuación, aparece la página del SQL editor.

3. La consola abre la página SQL del editor. Revise la página, incluidos los botones (Añadir SQL desde plantillas, Guardar y ejecutar SQL) y varias pestañas.

4. En el SQL editor, selecciona Añadir SQL desde plantillas.

5. En la lista de plantillas disponibles, elija Continuous filter. El código de muestra lee datos de una secuencia en la aplicación (la cláusula WHERE filtra las filas) y los introduce en otra secuencia en la aplicación de la siguiente manera:

   • Crea la secuencia en la aplicación DESTINATION_SQL_STREAM.

   • Crea una bomba STREAM_PUMP y la utiliza para seleccionar filas de SOURCE_SQL_STREAM_001 e insertarlas en el DESTINATION_SQL_STREAM.

6. Selecciona Añadir esto SQL al editor.

7. Pruebe el código de la aplicación de la siguiente manera:

   Recuerde que ya ha iniciado la solicitud (el estado esRUNNING). Por lo tanto, Amazon Kinesis Data Analytics ya está leyendo de manera continua desde el origen de streaming y añadiendo filas a la secuencia en la aplicación SOURCE_SQL_STREAM_001.

   1. En el SQL editor, selecciona Guardar y ejecutar SQL. La consola primero envía la solicitud de actualización para guardar el código de la aplicación. Luego el código se ejecuta de forma continua.

   2. Puede ver los resultados en la pestaña Real-time analytics.

      

      El SQL editor tiene las siguientes pestañas:

      • La pestaña Source data muestra una secuencia de entrada en la aplicación que se asigna al origen de streaming. Elija la secuencia en la aplicación y podrá ver los datos entrantes. Observe las columnas adicionales de la secuencia de entrada en la aplicación que no se especificaron en la configuración de entrada y que Incluyen las siguientes columnas de marca de tiempo:

         

        • ROWTIME— Cada fila de una secuencia integrada en la aplicación tiene una columna especial llamadaROWTIME. Esta columna es la marca de tiempo cuando Amazon Kinesis Data Analytics inserta la fila en la primera secuencia en la aplicación (la secuencia de entrada en la aplicación que se asigna al origen de streaming).

           

        • Approximate_Arrival_Time: cada registro de Kinesis Data Analytics incluye un valor denominado Approximate_Arrival_Time. Este valor es la marca de tiempo aproximado de llegada que se establece cuando el origen de streaming recibe y almacena correctamente el registro. Cuando Kinesis Data Analytics lee registros de un origen de streaming, incluye esta columna en la secuencia de entrada en la aplicación.

        Estos valores de marca de tiempo resultan útiles en consultas de ventanas basadas en el tiempo. Para obtener más información, consulte Consultas en ventana.

         

      • La pestaña Real-time analytics muestra todas las demás secuencias en la aplicación que crea el código de la aplicación. También incluye la secuencia de errores. Kinesis Data Analytics envía las filas que no puede procesar a la secuencia de errores. Para obtener más información, consulte Control de errores.

         

        Elija DESTINATION_SQL_STREAM para ver las filas que el código de su aplicación ha insertado. Observe las columnas adicionales que el código de la aplicación no ha creado. Estas columnas incluyen las columnas de marca de tiempo ROWTIME. Kinesis Data Analytics simplemente copia estos valores de la fuente (SOURCE_SQL_STREAM_001).

         

      • La pestaña Destino muestra el destino externo en el que Kinesis Data Analytics escribe los resultados de la consulta. Aún no ha configurado ningún destino externo para la salida de la aplicación.

Paso siguiente

Paso 3.4 (opcional): actualizar el código de la aplicación