使用适用于 Apache Flink 的托管服务 VPC API - Managed Service for Apache Flink
创建应用程序AddApplicationVpcConfigurationDeleteApplicationVpcConfiguration更新应用程序

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用适用于 Apache Flink 的托管服务 VPC API

使用以下适用于 Apache Flink API 操作的托管服务来管理VPCs您的应用程序。有关使用适用于 Apache Flink 的托管服务的信息API，请参阅。适用于 Apache 的托管服务 Flink 示例代码 API

创建应用程序

在创建应用程序期间，使用CreateApplication操作向应用程序添加VPC配置。

以下CreateApplication操作的示例请求代码包括创建应用程序时的VPC配置：

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

在创建VPC配置后，使用AddApplicationVpcConfiguration操作向应用程序添加配置。

以下AddApplicationVpcConfiguration操作的示例请求代码为现有应用程序添加VPC配置：

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfiguration": { 
      "SecurityGroupIds": [ "sg-0123456789abcdef0" ],
      "SubnetIds": [ "subnet-0123456789abcdef0" ]
   }
}

DeleteApplicationVpcConfiguration

使用DeleteApplicationVpcConfiguration操作从应用程序中移除VPC配置。

以下AddApplicationVpcConfiguration操作的示例请求代码将从应用程序中移除现有VPC配置：

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfigurationId": "1.1"
}

更新应用程序

使用UpdateApplication操作可以一次性更新应用程序的所有VPC配置。

以下UpdateApplication操作的示例请求代码更新了应用程序的所有VPC配置：

{
   "ApplicationConfigurationUpdate": { 
      "VpcConfigurationUpdates": [ 
         { 
            "SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ],
            "SubnetIdUpdates": [ "subnet-0123456789abcdef0" ],
            "VpcConfigurationId": "2.1"
         }
      ]
   },
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9
}