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 }