Use a API de VPC do Managed Service for Apache Flink

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 Exemplo de código de API para o Managed Service for Apache Flink.

Criar aplicação

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"
}
            

Atualize o 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
}