O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente 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 serviço gerenciado para a API Apache Flink VPC
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 }