DiscoverInputSchema - Amazon Managed Service para Apache Flink (anteriormente Amazon Kinesis Data Analytics para Apache Flink)

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.

DiscoverInputSchema

Infiere un esquema para una aplicación de Kinesis Data Analytics basada en SQL mediante la evaluación de registros de muestra en la fuente de streaming especificada (transmisión de datos de Kinesis o transmisión de entrega de Kinesis Data Firehose) o en el objeto de Amazon S3. En la respuesta, la operación devuelve el esquema inferido y también los registros de muestra que la operación utilizó para deducir el esquema.

Puede usar el esquema inferido al configurar un origen de flujo para su aplicación. Al crear una aplicación mediante la consola de Kinesis Data Analytics, la consola utiliza esta operación para deducir un esquema y mostrarlo en la interfaz de usuario de la consola.

Sintaxis de la solicitud

{ "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "string" }, "ResourceARN": "string", "S3Configuration": { "BucketARN": "string", "FileKey": "string" }, "ServiceExecutionRole": "string" }

Parámetros de la solicitud

La solicitud acepta los siguientes datos en formato JSON.

InputProcessingConfiguration

Utilice InputProcessingConfiguration para preprocesar los registros antes de detectar el esquema de los registros.

Tipo: objeto InputProcessingConfiguration

Obligatorio: no

InputStartingPositionConfiguration

El punto en el que desea que Kinesis Data Analytics comience a leer los registros de la fuente de streaming especificada con fines de descubrimiento.

Tipo: objeto InputStartingPositionConfiguration

Obligatorio: no

ResourceARN

El nombre de recurso de Amazon (ARN) del origen de transmisión.

Tipo: string

Limitaciones de longitud: longitud mínima de 1. La longitud máxima es de 2048 caracteres.

Patrón: arn:.*

Obligatorio: no

S3Configuration

Especifique este parámetro para descubrir un esquema a partir de datos en un objeto de Amazon S3.

Tipo: objeto S3Configuration

Obligatorio: no

ServiceExecutionRole

El ARN del rol que concede acceso al origen de transmisión.

Tipo: string

Limitaciones de longitud: longitud mínima de 1. La longitud máxima es de 2048 caracteres.

Patrón: arn:.*

Obligatorio: sí

Sintaxis de la respuesta

{ "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "ParsedInputRecords": [ [ "string" ] ], "ProcessedInputRecords": [ "string" ], "RawInputRecords": [ "string" ] }

Elementos de respuesta

Si la acción se realiza correctamente, el servicio devuelve una respuesta HTTP 200.

El servicio devuelve los datos siguientes en formato JSON.

InputSchema

El esquema deducido del origen de transmisión. Identifica el formato de los datos del origen de transmisión y cómo se asigna cada elemento de datos a las columnas correspondientes en el flujo dentro de la aplicación que puede crear.

Tipo: objeto SourceSchema

ParsedInputRecords

Conjunto de elementos, donde cada elemento corresponde a una fila de un registro de flujo (un registro de flujo puede tener más de una fila).

Tipo: matrices de cadenas

ProcessedInputRecords

El flujo de datos que el procesador especificado modificó en el parámetro InputProcessingConfiguration.

Tipo: matriz de cadenas

RawInputRecords

El flujo de datos sin procesar que se mostraron para deducir el esquema.

Tipo: matriz de cadenas

Errores

InvalidArgumentException

El valor del parámetro de entrada especificado no es válido.

Código de estado HTTP: 400

InvalidRequestException

El JSON de la solicitud no es válido para la operación.

Código de estado HTTP: 400

ResourceProvisionedThroughputExceededException

El servicio de detección no pudo obtener un registro del origen de transmisión debido a una ProvisionedThroughputExceededException de Kinesis Streams. Para obtener más información, consulte la referencia GetRecordsde la API de Amazon Kinesis Streams.

Código de estado HTTP: 400

ServiceUnavailableException

El servicio no puede completar la solicitud.

Código de estado HTTP: 500

UnableToDetectSchemaException

El formato de los datos no es válido. Kinesis Data Analytics no puede detectar el esquema de la fuente de transmisión determinada.

Código de estado HTTP: 400

UnsupportedOperationException

La solicitud se rechazó porque no se admite un parámetro especificado o porque un recurso especificado no es válido para esta operación.

Código de estado HTTP: 400

Véase también

Para obtener más información sobre el uso de esta API en uno de los AWS SDK específicos del idioma, consulte lo siguiente: