Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.
Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Verwenden Sie den folgenden Managed Service für Apache Flink API-Operationen, um Ihre Anwendung VPCs zu verwalten. Weitere Informationen zur Verwendung der API von Managed Service für Apache Flink finden Sie unter Beispielcode für Managed Service für Apache Flink API.
Anwendung erstellen
Verwenden Sie die CreateApplicationAktion, um Ihrer Anwendung während der Erstellung eine VPC-Konfiguration hinzuzufügen.
Der folgende Beispiel-Anforderungscode für die CreateApplication
-Aktion schließt eine VPC-Konfiguration ein, wenn die Anwendung erstellt wird:
{
"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
Verwenden Sie die AddApplicationVpcConfigurationAktion, um Ihrer Anwendung eine VPC-Konfiguration hinzuzufügen, nachdem sie erstellt wurde.
Der folgende Beispiel-Anforderungscode für die AddApplicationVpcConfiguration
-Aktion fügt einer bestehenden Anwendung eine VPC-Konfiguration hinzu:
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfiguration": {
"SecurityGroupIds": [ "sg-0123456789abcdef0" ],
"SubnetIds": [ "subnet-0123456789abcdef0" ]
}
}
DeleteApplicationVpcConfiguration
Verwenden Sie die DeleteApplicationVpcConfigurationAktion, um eine VPC-Konfiguration aus Ihrer Anwendung zu entfernen.
Der folgende Beispiel-Anforderungscode für die AddApplicationVpcConfiguration
-Aktion entfernt eine bestehende VPC-Konfiguration aus einer Anwendung:
{
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9,
"VpcConfigurationId": "1.1"
}
Anwendung aktualisieren
Verwenden Sie die UpdateApplicationAktion, um alle VPC-Konfigurationen einer Anwendung gleichzeitig zu aktualisieren.
Der folgende Beispiel-Anforderungscode für die UpdateApplication
-Aktion aktualisiert alle VPC-Konfigurationen einer Anwendung:
{
"ApplicationConfigurationUpdate": {
"VpcConfigurationUpdates": [
{
"SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ],
"SubnetIdUpdates": [ "subnet-0123456789abcdef0" ],
"VpcConfigurationId": "2.1"
}
]
},
"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 9
}