AddApplicationInputProcessingConfiguration - Amazon Managed Service pour Apache Flink (anciennement Amazon Kinesis Data Analytics pour Apache Flink)

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.

AddApplicationInputProcessingConfiguration

Ajoute un InputProcessingConfiguration à une application Kinesis Data Analytics basée sur SQL. Un processeur d'entrée prétraite les enregistrements du flux d'entrée avant que le code SQL de l'application ne soit exécuté. Actuellement, le seul processeur d'entrée disponible est Amazon Lambda.

Syntaxe de la requête

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "InputId": "string", "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } } }

Paramètres de demande

Cette demande accepte les données suivantes au format JSON.

ApplicationName

Nom de l'application à laquelle vous souhaitez ajouter la configuration de traitement des entrées.

Type : chaîne

Contraintes de longueur : Longueur minimum de 1. Longueur maximale de 128.

Modèle : [a-zA-Z0-9_.-]+

Obligatoire : oui

CurrentApplicationVersionId

Version de l'application à laquelle vous souhaitez ajouter la configuration de traitement des entrées. Vous pouvez utiliser cette DescribeApplication opération pour obtenir la version actuelle de l'application. Si la version spécifiée n’est pas la version actuelle, ConcurrentModificationException est renvoyé.

Type : long

Plage valide : valeur minimum de 1. Valeur maximale de 999999999.

Obligatoire : oui

InputId

ID de la configuration d’entrée à laquelle ajouter la configuration de traitement d’entrée. Vous pouvez obtenir une liste des identifiants d'entrée pour une application à l'aide de cette DescribeApplication opération.

Type : chaîne

Contraintes de longueur : longueur minimum de 1. Longueur maximale de 50.

Modèle : [a-zA-Z0-9_.-]+

Obligatoire : oui

InputProcessingConfiguration

Le InputProcessingConfiguration à ajouter à l'application.

Type : objet InputProcessingConfiguration

Obligatoire : oui

Syntaxe de la réponse

{ "ApplicationARN": "string", "ApplicationVersionId": number, "InputId": "string", "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "ResourceARN": "string", "RoleARN": "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.

ApplicationARN

Amazon Resource Name (ARN) de l'application.

Type : chaîne

Contraintes de longueur : longueur minimum de 1. Longueur maximale de 2048.

Modèle : arn:.*

ApplicationVersionId

Fournit la version d’application actuelle.

Type : long

Plage valide : valeur minimum de 1. Valeur maximale de 999999999.

InputId

L'ID d'entrée associé à l'entrée de l'application. Il s'agit de l'identifiant que Kinesis Data Analytics attribue à chaque configuration d'entrée que vous ajoutez à votre application.

Type : chaîne

Contraintes de longueur : longueur minimum de 1. Longueur maximale de 50.

Modèle : [a-zA-Z0-9_.-]+

InputProcessingConfigurationDescription

Description du préprocesseur qui s’exécute sur les enregistrements de cette entrée avant que le code de l’application ne soit exécuté.

Type : objet InputProcessingConfigurationDescription

Erreurs

ConcurrentModificationException

Exception déclenchée à la suite de modifications simultanées apportées à une application. Cette erreur peut être le résultat d'une tentative de modification d'une application sans utiliser l'ID d'application actuel.

Code d’état HTTP : 400

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 la requête n'est pas valide pour l'opération.

Code d’état HTTP : 400

ResourceInUseException

L'application n'est pas disponible pour cette opération.

Code d’état HTTP : 400

ResourceNotFoundException

L’application spécifiée est introuvable.

Code d’état HTTP : 400

consultez aussi

Pour plus d'informations sur l'utilisation de cette API dans l'un des AWS SDK spécifiques au langage, consultez les pages suivantes :