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 experimente ciertos problemas conocidos con las dependencias de Python de PyFlink 1.15. En este caso, recomendamos ejecutar el intérprete de Python en Docker. Para obtener instrucciones paso a paso, consulte PyFlink 1.15 development on Apple Silicon Mac.

La versión 1.20 de Apache Flink incluye soporte para crear aplicaciones con Python versión 3.11. 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.