Amazon Managed Service for Apache Flink (Amazon MSF) は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

Managed Service for Apache Flink VPC API を使用する

次の Apache Flink API オペレーション用 Managed Service を使用して、アプリケーションの VPC を管理します。Apache Flink API 用 Managed Serviceの使用方法については、 Managed Service for 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

アプリケーションから VPC 構成を削除するには、「DeleteApplicationVpcConfiguration」アクションを使用します。

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
}