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.
Paso 3: Configurar la salida de la aplicación
Una vez completado el Paso 2: Cree una aplicación, dispone de código de la aplicación que lee datos de frecuencia cardíaca de un origen de streaming y asigna una puntuación de anomalías a cada uno de ellos.
Ahora puede enviar el resultado de la aplicación desde la secuencia en la hasta un destino externo, que es otra secuencia de datos de Kinesis (OutputStreamTestingAnomalyScores). Puede analizar las puntuaciones de anomalías y determinar qué frecuencia cardíaca es anómala. Puede ampliar aún más esta aplicación para generar alertas.
Siga estos pasos para configurar la salida de la aplicación:
-
Abra la consola de Amazon Kinesis Data Analytics. En el editor de SQL, puede elegir tanto Destination como Add a destination en el panel de la aplicación.
-
En la página Connect to destination (Conectarse a un destino), elija la secuencia
OutputStreamTestingAnomalyScoresque ha creado en la sección anterior.Ahora tiene un destino externo, donde Amazon Kinesis Data Analytics persiste en cualquier registro que escriba su aplicación en la secuencia en la aplicación
DESTINATION_SQL_STREAM. -
Si lo desea, puede configurar AWS Lambda para monitorear la secuencia
OutputStreamTestingAnomalyScoresy enviarle alertas. Para obtener instrucciones, consulte Procesamiento previo de registros con una función de Lambda. Si no configura alertas, puede revisar los registros que Kinesis Data Analytics escribe en el destino externo, que es flujo de datos Kinesis deOutputStreamTestingAnomalyScores, tal como se describe en Paso 4: Verificar la salida.
Paso siguiente
