Creación de su aplicación Python de Managed Service para Apache Flink

Especificación de sus 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, se crea la aplicación mediante la consola o la acción CreateApplication.

Al crear la aplicación mediante la acción CreateApplication, se especifican los archivos de código y los archivos zip mediante un grupo de propiedades de aplicación especial denominado. kinesis.analytics.flink.run.options Puede definir los siguientes tipos de archivos:

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

• jarfile: archivo JAR de Java que contiene funciones de 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 archivos de recursos para la aplicación.

Para obtener más información sobre los tipos de archivos de código Python de Apache Flink, consulte Command-Line Interface 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"
          }
        },