Cree su servicio gestionado para la aplicación Apache Flink Python - Managed Service para Apache Flink
Especifica tus archivos de código

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.

Cree su servicio gestionado para la aplicación Apache Flink Python

Especifica tus archivos de código

Una vez que se crea el paquete de código de la aplicación, se carga a un bucket de Amazon S3. A continuación, crea la aplicación mediante la consola o la CreateApplicationacción.

Al crear la aplicación mediante la CreateApplicationacción, se especifican los archivos de código y se archivan en el archivo zip mediante un grupo de propiedades de la aplicación especial denominadokinesis.analytics.flink.run.options. Puede definir los siguientes tipos de archivos:

  • python: archivo de texto que contiene un método principal de Python.

  • jarfile: JAR archivo Java que contiene funciones Java definidas por el usuario.

  • pyFiles: un archivo de recursos de Python que contiene los recursos que utilizará la aplicación.

  • pyArchives: un archivo zip que contiene los archivos de recursos de la aplicación.

Para obtener más información sobre los tipos de archivos de código Python de Apache Flink, consulte Interfaz de línea de comandos en la documentación de Apache Flink.

nota

Managed Service para Apache Flink no admite los tipos de archivo pyModule, pyExecutable, o pyRequirements. Todo el código, los requisitos y las dependencias deben estar en el archivo zip. No puede especificar las dependencias que se instalarán mediante pip.

El siguiente fragmento json de ejemplo muestra cómo especificar las ubicaciones de los archivos dentro del archivo zip de la aplicación:

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },