Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Gunakan Layanan Terkelola untuk Apache Flink VPC API
Gunakan Layanan Terkelola berikut untuk API operasi Apache Flink VPCs untuk mengelola aplikasi Anda. Untuk informasi tentang penggunaan Layanan Terkelola untuk Apache FlinkAPI, lihat. Layanan Terkelola untuk kode contoh Apache Flink API
Buat aplikasi
Gunakan CreateApplicationtindakan untuk menambahkan VPC konfigurasi ke aplikasi Anda selama pembuatan.
Contoh kode permintaan berikut untuk CreateApplication
tindakan mencakup VPC konfigurasi saat aplikasi dibuat:
{ "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
Gunakan AddApplicationVpcConfigurationtindakan untuk menambahkan VPC konfigurasi ke aplikasi Anda setelah dibuat.
Contoh kode permintaan berikut untuk AddApplicationVpcConfiguration
tindakan menambahkan VPC konfigurasi ke aplikasi yang ada:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfiguration": { "SecurityGroupIds": [ "sg-0123456789abcdef0" ], "SubnetIds": [ "subnet-0123456789abcdef0" ] } }
DeleteApplicationVpcConfiguration
Gunakan DeleteApplicationVpcConfigurationtindakan untuk menghapus VPC konfigurasi dari aplikasi Anda.
Contoh kode permintaan berikut untuk AddApplicationVpcConfiguration
tindakan menghapus VPC konfigurasi yang ada dari aplikasi:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfigurationId": "1.1" }
Perbarui aplikasi
Gunakan UpdateApplicationtindakan untuk memperbarui semua VPC konfigurasi aplikasi sekaligus.
Contoh kode permintaan berikut untuk UpdateApplication
tindakan memperbarui semua VPC konfigurasi untuk aplikasi:
{ "ApplicationConfigurationUpdate": { "VpcConfigurationUpdates": [ { "SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ], "SubnetIdUpdates": [ "subnet-0123456789abcdef0" ], "VpcConfigurationId": "2.1" } ] }, "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9 }