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.
# Exemple de code de service géré pour l'API Apache Flink
Cette rubrique contient un exemple de blocs de requêtes pour les actions du service géré pour Apache Flink.
Pour utiliser le JSON comme entrée pour une action avec le AWS Command Line Interface (AWS CLI), enregistrez la demande dans un fichier JSON. Transmettez ensuite le nom du fichier à l’action à l’aide du paramètre `--cli-input-json`.
L’exemple suivant montre comment utiliser un fichier JSON avec une action.
```
$ aws kinesisanalyticsv2 start-application --cli-input-json file://start.json
```
Pour plus d'informations sur l'utilisation de JSON avec le AWS CLI, consultez [Generate CLI Skeleton and CLI Input JSON Parameters](https://docs.aws.amazon.com/cli/latest/userguide/generate-cli-skeleton.html) dans le *guide de AWS Command Line Interface l'utilisateur*.
**Topics**
+ [AddApplicationCloudWatchLoggingOption](#api-examples-addapplicationcloudwatchloggingoption)
+ [AddApplicationInput](#api-examples-addapplicationinput)
+ [AddApplicationInputProcessingConfiguration](#api-examples-addapplicationinputprocessingconfiguration)
+ [AddApplicationOutput](#api-examples-addapplicationoutput)
+ [AddApplicationReferenceDataSource](#api-examples-addapplicationreferencedatasource)
+ [AddApplicationVpcConfiguration](#api-examples-AddApplicationVpcConfiguration)
+ [CreateApplication](#api-examples-createapplication)
+ [CreateApplicationSnapshot](#api-examples-createapplicationsnapshot)
+ [DeleteApplication](#api-examples-deleteapplication)
+ [DeleteApplicationCloudWatchLoggingOption](#api-examples-deleteapplicationcloudwatchloggingoption)
+ [DeleteApplicationInputProcessingConfiguration](#api-examples-deleteapplicationinputprocessingconfiguration)
+ [DeleteApplicationOutput](#api-examples-deleteapplicationoutput)
+ [DeleteApplicationReferenceDataSource](#api-examples-deleteapplicationreferencedatasource)
+ [DeleteApplicationSnapshot](#api-examples-deleteapplicationsnapshot)
+ [DeleteApplicationVpcConfiguration](#api-examples-DeleteApplicationVpcConfiguration)
+ [DescribeApplication](#api-examples-describeapplication)
+ [DescribeApplicationSnapshot](#api-examples-describeapplicationsnapshot)
+ [DiscoverInputSchema](#api-examples-discoverinputschema)
+ [ListApplications](#api-examples-listapplications)
+ [ListApplicationSnapshots](#api-examples-listapplicationsnapshots)
+ [StartApplication](#api-examples-startapplication)
+ [StopApplication](#api-examples-stopapplication)
+ [UpdateApplication](#api-examples-updateapplication)
## AddApplicationCloudWatchLoggingOption
L'exemple de code de demande suivant pour l'[AddApplicationCloudWatchLoggingOption](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationCloudWatchLoggingOption.html)action ajoute une option de CloudWatch journalisation Amazon à une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CloudWatchLoggingOption": {
"LogStreamARN": "arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream"
},
"CurrentApplicationVersionId": 2
}
```
## AddApplicationInput
L'exemple de code de demande suivant pour l'[AddApplicationInput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationInput.html)action ajoute une entrée d'application à une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 2,
"Input": {
"InputParallelism": {
"Count": 2
},
"InputSchema": {
"RecordColumns": [
{
"Mapping": "$.TICKER",
"Name": "TICKER_SYMBOL",
"SqlType": "VARCHAR(50)"
},
{
"SqlType": "REAL",
"Name": "PRICE",
"Mapping": "$.PRICE"
}
],
"RecordEncoding": "UTF-8",
"RecordFormat": {
"MappingParameters": {
"JSONMappingParameters": {
"RecordRowPath": "$"
}
},
"RecordFormatType": "JSON"
}
},
"KinesisStreamsInput": {
"ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream"
}
}
}
```
## AddApplicationInputProcessingConfiguration
L'exemple de code de demande suivant pour l'[AddApplicationInputProcessingConfiguration](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationInputProcessingConfiguration.html)action ajoute une configuration de traitement des entrées d'application à une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 2,
"InputId": "2.1",
"InputProcessingConfiguration": {
"InputLambdaProcessor": {
"ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
}
}
}
```
## AddApplicationOutput
L'exemple de code de demande suivant pour l'[AddApplicationOutput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationOutput.html)action ajoute un flux de données Kinesis en tant que sortie d'application à une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 2,
"Output": {
"DestinationSchema": {
"RecordFormatType": "JSON"
},
"KinesisStreamsOutput": {
"ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleOutputStream"
},
"Name": "DESTINATION_SQL_STREAM"
}
}
```
## AddApplicationReferenceDataSource
L'exemple de code de demande suivant pour l'[AddApplicationReferenceDataSource](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_AddApplicationReferenceDataSource.html)action ajoute une source de données de référence d'application CSV à une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 5,
"ReferenceDataSource": {
"ReferenceSchema": {
"RecordColumns": [
{
"Mapping": "$.TICKER",
"Name": "TICKER",
"SqlType": "VARCHAR(4)"
},
{
"Mapping": "$.COMPANYNAME",
"Name": "COMPANY_NAME",
"SqlType": "VARCHAR(40)"
},
],
"RecordEncoding": "UTF-8",
"RecordFormat": {
"MappingParameters": {
"CSVMappingParameters": {
"RecordColumnDelimiter": " ",
"RecordRowDelimiter": "\r\n"
}
},
"RecordFormatType": "CSV"
}
},
"S3ReferenceDataSource": {
"BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
"FileKey": "TickerReference.csv"
},
"TableName": "string"
}
}
```
## AddApplicationVpcConfiguration
L’exemple de code de demande suivant pour l’action [AddApplicationVpcConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_AddApplicationVpcConfiguration.html) ajoute une configuration VPC à une application existante :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfiguration": {
"SecurityGroupIds": [ "sg-0123456789abcdef0" ],
"SubnetIds": [ "subnet-0123456789abcdef0" ]
}
}
```
## CreateApplication
L'exemple de code de demande suivant pour l'[CreateApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_CreateApplication.html)action crée un service géré pour l'application Apache Flink :
```
{
"ApplicationName":"MyApplication",
"ApplicationDescription":"My-Application-Description",
"RuntimeEnvironment":"FLINK-1_15",
"ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole",
"CloudWatchLoggingOptions":[
{
"LogStreamARN":"arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream"
}
],
"ApplicationConfiguration": {
"EnvironmentProperties":
{"PropertyGroups":
[
{"PropertyGroupId": "ConsumerConfigProperties",
"PropertyMap":
{"aws.region": "us-east-1",
"flink.stream.initpos": "LATEST"}
},
{"PropertyGroupId": "ProducerConfigProperties",
"PropertyMap":
{"aws.region": "us-east-1"}
},
]
},
"ApplicationCodeConfiguration":{
"CodeContent":{
"S3ContentLocation":{
"BucketARN":"arn:aws:s3:::amzn-s3-demo-bucket",
"FileKey":"myflink.jar",
"ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
}
},
"CodeContentType":"ZIPFILE"
},
"FlinkApplicationConfiguration":{
"ParallelismConfiguration":{
"ConfigurationType":"CUSTOM",
"Parallelism":2,
"ParallelismPerKPU":1,
"AutoScalingEnabled":true
}
}
}
}
```
## CreateApplicationSnapshot
L'exemple de code de demande suivant pour l'[CreateApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_CreateApplicationSnapshot.html)action crée un instantané de l'état de l'application :
```
{
"ApplicationName": "MyApplication",
"SnapshotName": "MySnapshot"
}
```
## DeleteApplication
L'exemple de code de demande suivant pour l'[DeleteApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplication.html)action supprime une application Managed Service for Apache Flink :
```
{"ApplicationName": "MyApplication",
"CreateTimestamp": 12345678912}
```
## DeleteApplicationCloudWatchLoggingOption
L'exemple de code de demande suivant pour l'[DeleteApplicationCloudWatchLoggingOption](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationCloudWatchLoggingOption.html)action supprime une option de CloudWatch journalisation Amazon d'une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CloudWatchLoggingOptionId": "3.1"
"CurrentApplicationVersionId": 3
}
```
## DeleteApplicationInputProcessingConfiguration
L'exemple de code de demande suivant pour l'[DeleteApplicationInputProcessingConfiguration](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationInputProcessingConfiguration.html)action supprime une configuration de traitement des entrées d'une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 4,
"InputId": "2.1"
}
```
## DeleteApplicationOutput
L'exemple de code de demande suivant pour l'[DeleteApplicationOutput](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationOutput.html)action supprime une sortie d'application d'une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 4,
"OutputId": "4.1"
}
```
## DeleteApplicationReferenceDataSource
L'exemple de code de demande suivant pour l'[DeleteApplicationReferenceDataSource](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationReferenceDataSource.html)action supprime une source de données de référence d'application d'une application Managed Service for Apache Flink :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 5,
"ReferenceId": "5.1"
}
```
## DeleteApplicationSnapshot
L'exemple de code de demande suivant pour l'[DeleteApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DeleteApplicationSnapshot.html)action supprime un instantané de l'état de l'application :
```
{
"ApplicationName": "MyApplication",
"SnapshotCreationTimestamp": 12345678912,
"SnapshotName": "MySnapshot"
}
```
## DeleteApplicationVpcConfiguration
L’exemple de code de demande suivant pour l’action [DeleteApplicationVpcConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_DeleteApplicationVpcConfiguration.html) supprime une configuration VPC existante d’une application :
```
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfigurationId": "1.1"
}
```
## DescribeApplication
L'exemple de code de demande suivant pour l'[DescribeApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DescribeApplication.html)action renvoie des informations sur une application Managed Service for Apache Flink :
```
{"ApplicationName": "MyApplication"}
```
## DescribeApplicationSnapshot
L'exemple de code de demande suivant pour l'[DescribeApplicationSnapshot](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DescribeApplicationSnapshot.html)action renvoie des détails sur un instantané de l'état de l'application :
```
{
"ApplicationName": "MyApplication",
"SnapshotName": "MySnapshot"
}
```
## DiscoverInputSchema
L'exemple de code de demande suivant pour l'[DiscoverInputSchema](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DiscoverInputSchema.html)action génère un schéma à partir d'une source de streaming :
```
{
"InputProcessingConfiguration": {
"InputLambdaProcessor": {
"ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
}
},
"InputStartingPositionConfiguration": {
"InputStartingPosition": "NOW"
},
"ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream",
"S3Configuration": {
"BucketARN": "string",
"FileKey": "string"
},
"ServiceExecutionRole": "string"
}
```
L'exemple de code de demande suivant pour l'[DiscoverInputSchema](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_DiscoverInputSchema.html)action génère un schéma à partir d'une source de référence :
```
{
"S3Configuration": {
"BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
"FileKey": "TickerReference.csv"
},
"ServiceExecutionRole": "arn:aws:iam::123456789123:role/myrole"
}
```
## ListApplications
L'exemple de code de demande suivant pour l'[ListApplications](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_ListApplications.html)action renvoie une liste des applications Managed Service for Apache Flink de votre compte :
```
{
"ExclusiveStartApplicationName": "MyApplication",
"Limit": 50
}
```
## ListApplicationSnapshots
L'exemple de code de demande suivant pour l'[ListApplicationSnapshots](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_ListApplicationSnapshots.html)action renvoie une liste d'instantanés de l'état de l'application :
```
{"ApplicationName": "MyApplication",
"Limit": 50,
"NextToken": "aBcDeFgHiJkLmNoPqRsTuVwXyZ0123"
}
```
## StartApplication
L'exemple de code de demande suivant pour l'[StartApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_StartApplication.html)action démarre une application Managed Service for Apache Flink et charge l'état de l'application à partir du dernier instantané (le cas échéant) :
```
{
"ApplicationName": "MyApplication",
"RunConfiguration": {
"ApplicationRestoreConfiguration": {
"ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
}
}
}
```
## StopApplication
L'exemple de code de demande suivant pour l'action [API\$1STopApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_StopApplication.html) arrête une application Managed Service for Apache Flink :
```
{"ApplicationName": "MyApplication"}
```
## UpdateApplication
L'exemple de code de demande suivant pour l'[UpdateApplication](https://docs.aws.amazon.com/managed-service-for-apache-flink/latest/apiv2/API_UpdateApplication.html)action met à jour une application Managed Service for Apache Flink afin de modifier l'emplacement du code de l'application :
```
{"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 1,
"ApplicationConfigurationUpdate": {
"ApplicationCodeConfigurationUpdate": {
"CodeContentTypeUpdate": "ZIPFILE",
"CodeContentUpdate": {
"S3ContentLocationUpdate": {
"BucketARNUpdate": "arn:aws:s3:::amzn-s3-demo-bucket",
"FileKeyUpdate": "my_new_code.zip",
"ObjectVersionUpdate": "2"
}
}
}
}
```