Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
DiscoverInputSchema
Déduit un schéma pour une application SQL-based Kinesis Data Analytics en évaluant des exemples d'enregistrements sur la source de streaming spécifiée (flux de données Kinesis ou flux de diffusion Kinesis Data Firehose) ou sur l'objet Amazon S3. Dans la réponse, l’opération renvoie le schéma déduit ainsi que les exemples d’enregistrements utilisés par l’opération pour déduire le schéma.
Vous pouvez utiliser le schéma déduit lors de la configuration d’une source de streaming pour votre application. Lorsque vous créez une application à l'aide de la console Kinesis Data Analytics, la console utilise cette opération pour déduire un schéma et l'afficher dans l'interface utilisateur de la console.
Syntaxe de la requête
{
"InputProcessingConfiguration": {
"InputLambdaProcessor": {
"ResourceARN": "string"
}
},
"InputStartingPositionConfiguration": {
"InputStartingPosition": "string"
},
"ResourceARN": "string",
"S3Configuration": {
"BucketARN": "string",
"FileKey": "string"
},
"ServiceExecutionRole": "string"
}Paramètres de demande
Cette demande accepte les données suivantes au format JSON.
- InputProcessingConfiguration
-
InputProcessingConfigurationÀ utiliser pour prétraiter les enregistrements avant de découvrir le schéma des enregistrements.
Type : objet InputProcessingConfiguration
Obligatoire : non
- InputStartingPositionConfiguration
-
Point auquel vous souhaitez que Kinesis Data Analytics commence à lire les enregistrements provenant de la source de diffusion spécifiée à des fins de découverte.
Type : objet InputStartingPositionConfiguration
Obligatoire : non
- ResourceARN
-
Le nom de ressource Amazon (ARN) de la source de streaming.
Type : Chaîne
Contraintes de longueur : longueur minimum de 1. Longueur maximale de 2048.
Modèle :
arn:.*Obligatoire : non
- S3Configuration
-
Spécifiez ce paramètre pour découvrir un schéma à partir des données d’un objet Amazon S3.
Type : objet S3Configuration
Obligatoire : non
- ServiceExecutionRole
-
L'ARN du rôle utilisé pour accéder à la source de diffusion.
Type : Chaîne
Contraintes de longueur : longueur minimum de 1. Longueur maximale de 2048.
Modèle :
arn:.*Obligatoire : oui
Syntaxe de la réponse
{
"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" ]
}Eléments de réponse
Si l’action aboutit, le service renvoie une réponse HTTP 200.
Les données suivantes sont renvoyées au format JSON par le service.
- InputSchema
-
Schéma déduit de la source de diffusion. Il identifie le format des données de la source de streaming et la façon dont chaque élément de données est mappé aux colonnes correspondantes que vous pouvez créer dans le flux intégré à l’application.
Type : objet SourceSchema
- ParsedInputRecords
-
Tableau d’éléments, où chaque élément correspond à une ligne d’un enregistrement de flux (un enregistrement de flux peut comporter plusieurs lignes).
Type : Tableau de tableaux de chaînes
- ProcessedInputRecords
-
Les données de flux qui ont été modifiées par le processeur spécifié dans le
InputProcessingConfigurationparamètre.Type : tableau de chaînes
- RawInputRecords
-
Les données de flux brutes qui ont été échantillonnées pour déduire le schéma.
Type : tableau de chaînes
Erreurs
- InvalidArgumentException
-
La valeur du paramètre d'entrée spécifiée n'est pas valide.
Code d’état HTTP : 400
- InvalidRequestException
-
Le JSON de requête n'est pas valide pour l'opération.
Code d’état HTTP : 400
- ResourceProvisionedThroughputExceededException
-
Discovery n'a pas pu obtenir d'enregistrement à partir de la source de diffusion à cause de Kinesis Streams
ProvisionedThroughputExceededException. Pour plus d'informations, consultez GetRecords la référence de l'API Amazon Kinesis Streams.Code d’état HTTP : 400
- ServiceUnavailableException
-
Le service ne peut pas traiter la demande.
Code d’état HTTP : 500
- UnableToDetectSchemaException
-
Le format de données n'est pas valide. Kinesis Data Analytics ne peut pas détecter le schéma de la source de streaming donnée.
- ProcessedInputRecords
-
Données de flux modifiées par le processeur spécifié dans le paramètre
InputProcessingConfiguration. - RawInputRecords
-
Données de flux brutes qui ont été échantillonnées pour déduire le schéma.
Code d’état HTTP : 400
- UnsupportedOperationException
-
La requête a été rejetée car un paramètre spécifié n’est pas pris en charge ou parce qu’une ressource spécifiée n’est pas valide pour cette opération.
Code d’état HTTP : 400
Voir aussi
Pour plus d'informations sur l'utilisation de cette API dans l'un des AWS kits SDK spécifiques à une langue, consultez les rubriques suivantes :
