Utilice el servicio gestionado para Apache Flink VPC API - Managed Service para Apache Flink

Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Utilice el servicio gestionado para Apache Flink VPC API

Utilice el siguiente servicio gestionado para gestionar API las operaciones de Apache Flink en su VPCs aplicación. Para obtener información sobre el uso del servicio gestionado para Apache FlinkAPI, consulte. Código de API ejemplo de Managed Service for Apache Flink

Crear aplicación

Utilice la CreateApplicationacción para añadir una VPC configuración a la aplicación durante la creación.

El siguiente ejemplo de código de solicitud para la CreateApplication acción incluye una VPC configuración cuando se crea la aplicación:

{ "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

Utilice la AddApplicationVpcConfigurationacción para añadir una VPC configuración a la aplicación una vez creada.

El siguiente ejemplo de código de solicitud para la AddApplicationVpcConfiguration acción agrega una VPC configuración a una aplicación existente:

{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfiguration": { "SecurityGroupIds": [ "sg-0123456789abcdef0" ], "SubnetIds": [ "subnet-0123456789abcdef0" ] } }

DeleteApplicationVpcConfiguration

Utilice la DeleteApplicationVpcConfigurationacción para eliminar una VPC configuración de la aplicación.

El siguiente ejemplo de código de solicitud para la AddApplicationVpcConfiguration acción elimina una VPC configuración existente de una aplicación:

{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 9, "VpcConfigurationId": "1.1" }

Actualizar la aplicación

Utilice la UpdateApplicationacción para actualizar todas las VPC configuraciones de una aplicación a la vez.

El siguiente ejemplo de código de solicitud para la UpdateApplication acción actualiza todas las VPC configuraciones de una aplicación:

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