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.
Ejemplos de Python
Los siguientes ejemplos muestran cómo crear aplicaciones escritas en Python.
nota
La mayoría de los ejemplos están diseñados para ejecutarse tanto de forma local, en la máquina de desarrollo y el IDE que prefiera, como en Amazon Managed Service para Apache Flink. En ellos se muestra el sencillo mecanismo que se puede utilizar para transferir los parámetros de la aplicación y cómo configurar la dependencia correctamente para ejecutar la aplicación en ambos entornos sin cambios.
Dependencias del proyecto
La mayoría de los PyFlink ejemplos requieren una o más dependencias en forma de archivos JAR, por ejemplo, conectores Flink o bibliotecas de terceros de Python. Estas dependencias no se incluyen en el repositorio de ejemplos. Debe descargarlas en su máquina antes de empaquetar la aplicación. Para obtener más información sobre las dependencias, consulte README:
Consulte la documentación de Flink para encontrar el enlace para descargar la versión correcta del conector que necesita. Utilice siempre la dependencia para la versión de Flink que esté utilizando. Las siguientes son las dependencias de conector que se utilizan con frecuencia para Flink 1.18:
Los siguientes ejemplos ya contienen el código necesario para configurar las dependencias.
Ejemplos
En este ejemplo, se muestra la estructura básica de una PyFlink aplicación que utiliza la Table API y SQL. También muestra cómo incluir una única dependencia JAR en PyFlink la aplicación. En este caso, incluimos el conector SQL de Kinesis.
Ejemplo de código: GettingStarted
Estos dos ejemplos demuestran la implementación de ventanas giratorias y deslizantes en tiempo de eventos mediante la API. Table Los ejemplos también ilustran cómo definir una marca de agua en la tabla fuente, que se utiliza para la creación de ventanas en el momento del evento. Ambos ejemplos también incluyen la dependencia JAR del conector SQL de Kinesis.
Ejemplos de código:
En este ejemplo, se muestra cómo escribir el resultado en Amazon S3 como archivos JSON. Debe activar los puntos de control en el receptor S3 para escribir y rotar archivos en Amazon S3.
Ejemplo de código: StreamingFileSink
