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 serviço gerenciado para o Apache Flink VPC API
Use o seguinte serviço gerenciado para API operações do Apache Flink VPCs para gerenciar seu aplicativo. Para obter informações sobre como usar o Managed Service para Apache FlinkAPI, consulte. Código de exemplo do Managed Service for Apache Flink API
Criar aplicativo
Use a CreateApplicationação para adicionar uma VPC configuração ao seu aplicativo durante a criação.
O exemplo a seguir de código de solicitação para a CreateApplication
ação inclui uma VPC configuração 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:::mybucket", "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 VPC configuração ao seu aplicativo após sua criação.
O exemplo a seguir de código de solicitação para a AddApplicationVpcConfiguration
ação adiciona uma VPC configuração a um aplicativo existente:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfiguration": { "SecurityGroupIds": [ "sg-0123456789abcdef0" ], "SubnetIds": [ "subnet-0123456789abcdef0" ] } }
DeleteApplicationVpcConfiguration
Use a DeleteApplicationVpcConfigurationação para remover uma VPC configuração do seu aplicativo.
O exemplo a seguir de código de solicitação para a AddApplicationVpcConfiguration
ação remove uma VPC configuração existente de um aplicativo:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfigurationId": "1.1" }
Atualizar aplicativo
Use a UpdateApplicationação para atualizar todas as VPC configurações de um aplicativo de uma só vez.
O exemplo a seguir de código de solicitação para a UpdateApplication
ação atualiza todas VPC as configurações de um aplicativo:
{ "ApplicationConfigurationUpdate": { "VpcConfigurationUpdates": [ { "SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ], "SubnetIdUpdates": [ "subnet-0123456789abcdef0" ], "VpcConfigurationId": "2.1" } ] }, "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9 }