Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.
Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Usa il servizio gestito per Apache Flink VPC API
Utilizza il seguente servizio gestito per le API operazioni di Apache Flink per gestire VPCs la tua applicazione. Per informazioni sull'utilizzo del servizio gestito per Apache API Flink, consulta. Codice di esempio di Managed Service per Apache Flink API
Crea applicazione
Utilizzate l'CreateApplicationazione per aggiungere una VPC configurazione all'applicazione durante la creazione.
Il seguente esempio di codice di richiesta per l'CreateApplication
azione include una VPC configurazione al momento della creazione dell'applicazione:
{ "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
Utilizzate l'AddApplicationVpcConfigurationazione per aggiungere una VPC configurazione all'applicazione dopo che è stata creata.
Il seguente codice di richiesta di esempio per l'AddApplicationVpcConfiguration
azione aggiunge una VPC configurazione a un'applicazione esistente:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfiguration": { "SecurityGroupIds": [ "sg-0123456789abcdef0" ], "SubnetIds": [ "subnet-0123456789abcdef0" ] } }
DeleteApplicationVpcConfiguration
Utilizzate l'DeleteApplicationVpcConfigurationazione per rimuovere una VPC configurazione dall'applicazione.
Il seguente esempio di codice di richiesta per l'AddApplicationVpcConfiguration
azione rimuove una VPC configurazione esistente da un'applicazione:
{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfigurationId": "1.1" }
Aggiorna l'applicazione
Utilizzate l'UpdateApplicationazione per aggiornare tutte le VPC configurazioni di un'applicazione contemporaneamente.
Il seguente codice di richiesta di esempio per l'UpdateApplication
azione aggiorna tutte le VPC configurazioni di un'applicazione:
{ "ApplicationConfigurationUpdate": { "VpcConfigurationUpdates": [ { "SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ], "SubnetIdUpdates": [ "subnet-0123456789abcdef0" ], "VpcConfigurationId": "2.1" } ] }, "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9 }