Uso de Python con Managed Service para Apache Flink - Managed Service 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.

Uso de Python con Managed Service para Apache Flink

nota

Si está desarrollando la aplicación Python Flink en una Mac nueva con el chip Apple Silicon, es posible que encuentre algunos problemas conocidos con las dependencias de Python de PyFlink la versión 1.15. En este caso, recomendamos ejecutar el intérprete de Python en Docker. Para obtener step-by-step instrucciones, consulta el desarrollo de la PyFlink versión 1.15 en Apple Silicon Mac.

La versión 2.2 de Apache Flink incluye soporte para la creación de aplicaciones con la versión 3.12 de Python; se ha eliminado la compatibilidad con la versión 3.8 de Python. Para obtener más información, consulte Flink Python Docs. Para crear una aplicación de Managed Service para Apache Flink mediante Python, haga lo siguiente:

  • Cree el código de su aplicación de Python como un archivo de texto con un método main.

  • Agrupe el archivo de código de la aplicación y cualquier dependencia de Python o Java en un archivo zip y cárguelo en un bucket de Amazon S3.

  • Cree su aplicación Managed Service para Apache Flink especificando la ubicación del código de Amazon S3, las propiedades y la configuración de la aplicación.

En un nivel alto, la API Python Table es un envoltorio alrededor de la API Java Table. Para obtener información sobre la API de tabla de Python, consulte Table API Tutorial en la documentación de Apache Flink.