Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
使用 Managed Service for Apache Flink VPC API
您可以使用下列 Managed Service for Apache Flink API 作業來管理應用程式的 VPC。如需如何使用 Managed Service for Apache Flink API 的相關資訊,請參閱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
使用 AddApplicationVpcConfiguration 動作可在建立 VPC 組態之後將其新增至應用程式。
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 }