Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.
As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Use o seguinte serviço gerenciado para operações da API Apache Flink VPCs para gerenciar seu aplicativo. Para obter informações sobre como usar a API do Managed Service for Apache Flink, consulte Código de exemplo do Managed Service for Apache Flink API.
Criar aplicativo
Use a CreateApplicationação para adicionar uma configuração de VPC ao seu aplicativo durante a criação.
O exemplo a seguir de código de solicitação para a ação CreateApplication inclui uma configuração de VPC quando o aplicativo é criado:
{
"ApplicationName":"MyApplication",
"ApplicationDescription":"My-Application-Description",
"RuntimeEnvironment":"FLINK-1_15",
"ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole",
"ApplicationConfiguration": {
"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
}
},
"VpcConfigurations": [
{
"SecurityGroupIds": [ "sg-0123456789abcdef0" ],
"SubnetIds": [ "subnet-0123456789abcdef0" ]
}
]
}
}AddApplicationVpcConfiguration
Use a AddApplicationVpcConfigurationação para adicionar uma configuração de VPC ao seu aplicativo depois que ele for criado.
O exemplo a seguir de código de solicitação para a ação AddApplicationVpcConfiguration adiciona uma configuração de VPC a um aplicativo existente:
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfiguration": {
"SecurityGroupIds": [ "sg-0123456789abcdef0" ],
"SubnetIds": [ "subnet-0123456789abcdef0" ]
}
}
DeleteApplicationVpcConfiguration
Use a DeleteApplicationVpcConfigurationação para remover uma configuração de VPC do seu aplicativo.
O exemplo de solicitação a seguir para a ação AddApplicationVpcConfiguration remove tags de um aplicativo:
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfigurationId": "1.1"
}
Atualizar aplicativo
Use a UpdateApplicationação para atualizar todas as configurações de VPC de um aplicativo de uma só vez.
O exemplo de código de solicitação a seguir para a ação UpdateApplication atualiza todas as configurações de VPC de um aplicativo:
{
"ApplicationConfigurationUpdate": {
"VpcConfigurationUpdates": [
{
"SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ],
"SubnetIdUpdates": [ "subnet-0123456789abcdef0" ],
"VpcConfigurationId": "2.1"
}
]
},
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9
}
