Control de errores - Guía para desarrolladores de aplicaciones de Amazon Kinesis Data Analytics para SQL

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.

Control de errores

Amazon Kinesis Data Analytics le devuelve los errores de API o SQL directamente. Para obtener más información sobre las operaciones de API, consulte Acciones. Para obtener más información sobre el control de errores de SQL, consulte Referencia de SQL de Amazon Kinesis Data Analytics.

Amazon Kinesis Data Analytics informa de errores de tiempo de ejecución mediante una secuencia de errores en la aplicación denominada error_stream.

Informar de los errores mediante una secuencia de errores en la aplicación

Amazon Kinesis Data Analytics informa de errores de tiempo de ejecución mediante una secuencia de errores en la aplicación denominada error_stream. Los siguientes ejemplos muestran algunos errores que pueden ocurrir:

  • Un registro leído desde el origen de streaming no cumple el esquema de entrada.

  • El código de la aplicación especifica división por cero.

  • Las filas están desordenadas (por ejemplo, un registro aparece en la secuencia con un valor ROWTIME que un usuario modificó y provoca hace que el registro esté desordenado).

  • Los datos de la secuencia de origen no se pueden convertir al tipo de datos especificado en el esquema (Error de coerción). Para obtener información sobre qué tipos de datos se pueden convertir, consulte Mapeo de tipos de datos JSON para los tipos de datos SQL

Recomendamos que gestione estos errores mediante programación en el código SQL o que conserve los datos en la secuencia de errores en un destino externo. Esto requiere que añada una configuración de salida (consulte Configuración de salida de la aplicación) a la aplicación. Para ver un ejemplo sobre cómo funciona la secuencia de errores en la aplicación, consulte Ejemplo: Exploración de la secuencia de errores en la aplicación.

nota

La aplicación Kinesis Data Analytics no puede obtener acceso mediante programación a la secuencia de errores, ni tampoco a modificarla, debido a que dicha secuencia se crea con la cuenta del sistema. Debe utilizar la salida de error para determinar los errores que pueda encontrar la aplicación. A continuación, escriba el código SQL de la aplicación para gestionar las condiciones de error previstas.

Esquema de la secuencia de errores

La secuencia de errores tiene el siguiente esquema:

Campo

Tipo de datos

Notas

ERROR_TIME

TIMESTAMP

El momento en el que se produjo el error

ERROR_LEVEL

VARCHAR (10)

ERROR_NAME

VARCHAR (32)

MESSAGE

VARCHAR (4096)

DATA_ROWTIME

TIMESTAMP

El tiempo de la fila del registro entrante

DATA_ROW

VARCHAR (49152)

Los datos codificados en hexadecimal en la fila original. Puede utilizar bibliotecas estándar para decodificar de forma hexadecimal este valor, o utilizar recursos web como este convertidor de hexadecimal a cadena.

PUMP_NAME

VARCHAR (128)

La bomba de origen, tal y como se define con CREATE PUMP