Usa il servizio gestito per Apache Flink VPC API - Servizio gestito per Apache Flink

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'CreateApplicationazione 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'AddApplicationVpcConfigurationazione 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'AddApplicationVpcConfigurationazione 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'UpdateApplicationazione aggiorna tutte le VPC configurazioni di un'applicazione:

{ "ApplicationConfigurationUpdate": { "VpcConfigurationUpdates": [ { "SecurityGroupIdUpdates": [ "sg-0123456789abcdef0" ], "SubnetIdUpdates": [ "subnet-0123456789abcdef0" ], "VpcConfigurationId": "2.1" } ] }, "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9 }