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: cadena
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: cadena
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
ProvisionedThroughputExceededExceptionde 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 idiomas específicos AWS SDKs, consulte lo siguiente:
