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.
AddApplicationInput
Ajoute une source de streaming à votre application Managed Service for Apache Flink basée sur SQL.
Vous pouvez ajouter une source de diffusion lorsque vous créez une application, ou vous pouvez utiliser cette opération pour ajouter une source de diffusion après avoir créé une application. Pour plus d'informations, consultez CreateApplication.
Toutes les mises à jour de la configuration, y compris l'ajout d'une source de streaming à l'aide de cette opération, débouchent sur une nouvelle version de l'application. Vous pouvez utiliser l'opération DescribeApplication pour rechercher la version de l'application actuelle.
Syntaxe de la requête
{
"ApplicationName": "string",
"CurrentApplicationVersionId": number,
"Input": {
"InputParallelism": {
"Count": number
},
"InputProcessingConfiguration": {
"InputLambdaProcessor": {
"ResourceARN": "string"
}
},
"InputSchema": {
"RecordColumns": [
{
"Mapping": "string",
"Name": "string",
"SqlType": "string"
}
],
"RecordEncoding": "string",
"RecordFormat": {
"MappingParameters": {
"CSVMappingParameters": {
"RecordColumnDelimiter": "string",
"RecordRowDelimiter": "string"
},
"JSONMappingParameters": {
"RecordRowPath": "string"
}
},
"RecordFormatType": "string"
}
},
"KinesisFirehoseInput": {
"ResourceARN": "string"
},
"KinesisStreamsInput": {
"ResourceARN": "string"
},
"NamePrefix": "string"
}
}Paramètres de demande
Cette demande accepte les données suivantes au format JSON.
- ApplicationName
-
Le nom de l'application existante à laquelle vous souhaitez ajouter la source de streaming.
Type : chaîne
Contraintes de longueur : Longueur minimum de 1. Longueur maximum de 128.
Modèle :
[a-zA-Z0-9_.-]+Obligatoire : oui
- CurrentApplicationVersionId
-
La version actuelle de votre application. Vous devez fournir le
ApplicationVersionIDou leConditionalTokenfichier .Vous pouvez utiliser l'DescribeApplicationopération pour trouver la version actuelle de l'application.Type : long
Plage valide : valeur minimum de 1. Valeur maximale de 999999999.
Obligatoire : oui
- Input
-
Le Input à ajouter.
Type : objet Input
Obligatoire : oui
Syntaxe de la réponse
{
"ApplicationARN": "string",
"ApplicationVersionId": number,
"InputDescriptions": [
{
"InAppStreamNames": [ "string" ],
"InputId": "string",
"InputParallelism": {
"Count": number
},
"InputProcessingConfigurationDescription": {
"InputLambdaProcessorDescription": {
"ResourceARN": "string",
"RoleARN": "string"
}
},
"InputSchema": {
"RecordColumns": [
{
"Mapping": "string",
"Name": "string",
"SqlType": "string"
}
],
"RecordEncoding": "string",
"RecordFormat": {
"MappingParameters": {
"CSVMappingParameters": {
"RecordColumnDelimiter": "string",
"RecordRowDelimiter": "string"
},
"JSONMappingParameters": {
"RecordRowPath": "string"
}
},
"RecordFormatType": "string"
}
},
"InputStartingPositionConfiguration": {
"InputStartingPosition": "string"
},
"KinesisFirehoseInputDescription": {
"ResourceARN": "string",
"RoleARN": "string"
},
"KinesisStreamsInputDescription": {
"ResourceARN": "string",
"RoleARN": "string"
},
"NamePrefix": "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.
- InputDescriptions
-
Décrit la configuration d’entrée de l’application.
Type : tableau d’objets InputDescription
Erreurs
- CodeValidationException
-
Le code d'application (requête) fourni par l'utilisateur n'est pas valide. Il peut s’agir d’une simple erreur de syntaxe.
Code d’état HTTP : 400
- 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 kits SDK AWS spécifiques au langage, consultez les ressources suivantes :
