Paso 3.2: Configurar la entrada

Para añadir un origen de streaming a su aplicación

1. En el página del centro de aplicaciones en la consola, elija Connect streaming data (Conectar datos de streaming).

   

2. En la página que aparece, revise lo siguiente:

   • Source en la que especifica un origen de streaming para la aplicación. Puede seleccionar una fuente de secuencia o crear una. En este ejercicio, deberá crear una nueva secuencia: la secuencia de demostración.

      

     De forma predeterminada, la consola nombra la secuencia de entrada en la aplicación que se crea como INPUT_SQL_STREAM_001. Para este ejercicio, mantenga este nombre tal como aparece.

      

     • Nombre de referencia de secuencia: esta opción muestra el nombre de la secuencia de entrada en la aplicación, SOURCE_SQL_STREAM_001, que se crea. Puede cambiar el nombre, pero para este ejercicio mantenga este nombre.

        

       En la configuración de entrada, asigna la secuencia de demostración a una secuencia de entrada en la aplicación que se crea. Cuando inicia la aplicación, Amazon Kinesis Data Analytics lee la secuencia de demostración de forma continua e introduce filas en la secuencia de entrada en la aplicación. Usted consulta esta secuencia de entrada en la aplicación en el código de la aplicación.

        

     • Preprocesamiento de registros con AWS Lambda: esta opción es donde especifica una expresión de AWS Lambda que modifica los registros en la secuencia de entrada antes de que se ejecute el código de la aplicación. En este ejercicio, deje la opción Disabled seleccionada. Para obtener más información acerca del procesamiento previo de Lambda, consulte Procesamiento previo de registros con una función de Lambda.

   Después de proporcionar toda la información de esta página, la consola envía una solicitud de actualización (consulte UpdateApplication) para añadirla configuración de entrada de la aplicación.

3. En la página Source, elija Configure a new stream.

4. Elija Create demo stream. La consola configura la entrada de la aplicación realizando las siguientes operaciones:

   • La consola crea un flujo de datos de Kinesis denominada kinesis-analytics-demo-stream.

   • La consola rellena la secuencia con datos de muestra de cotizaciones bursátiles.

   • Mediante la acción de entrada DiscoverInputSchema, la consola infiere un esquema leyendo los registros de ejemplo de la secuencia. El esquema que se infiere es el esquema de la secuencia de entrada en la aplicación que se crea. Para obtener más información, consulte Configuración de entrada de la aplicación.

   • La consola muestra el esquema inferido y los datos de muestra que lee desde el origen de streaming a fin de inferir el esquema.

   La consola exhibe los registros de muestra en el origen de streaming.

   

   Esto es lo que se muestra en la página Stream sample de la consola:

   • La pestaña Raw stream sample muestra los registros de secuencias sin procesar muestreados mediante la acción de la API DiscoverInputSchema para inferir el esquema.

   • La pestaña Formatted stream sample exhibe la versión tabular de los datos en la pestaña Raw stream sample.

   • Si elige Edit schema, puede editar el esquema inferido. Para este ejercicio, no cambie el esquema inferido. Para obtener más información sobre la edición de un esquema, consulte Uso del editor de esquemas.

     Si elige Rediscover schema, puede solicitar a la consola que ejecute de nuevo DiscoverInputSchema e infiera el esquema.

5. Elija Guardar y continuar.

   Ahora tiene una aplicación con la configuración de entrada incorporada. En el siguiente paso, añada el código SQL para realizar un análisis de los datos en la secuencia de entrada en la aplicación.