View a markdown version of this page

Utiliser Python avec le service géré pour Apache Flink - Service géré pour Apache Flink

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Utiliser Python avec le service géré pour Apache Flink

Note

Si vous développez l'application Python Flink sur un nouveau Mac équipé d'une puce Apple Silicon, vous pouvez rencontrer des problèmes connus liés aux dépendances Python de la version PyFlink 1.15. Dans ce cas, nous recommandons d’exécuter l’interpréteur Python dans Docker. Pour obtenir des instructions détaillées, reportez-vous à la section Développement de la version PyFlink 1.15 sur Apple Silicon Mac.

La version 2.2 d'Apache Flink inclut la prise en charge de la création d'applications à l'aide de Python version 3.12 ; la prise en charge de Python version 3.8 est supprimée. Pour plus d'informations, consultez Flink Python Docs. Pour créer une application de service géré pour Apache Flink à l’aide de Python, procédez comme suit :

  • Créez le code de votre application Python sous forme de fichier texte avec une méthode main.

  • Regroupez le fichier de code de votre application et toutes les dépendances Python ou Java dans un fichier zip, puis chargez-le dans un compartiment Amazon S3.

  • Créez votre application de service géré pour Apache Flink, en spécifiant l’emplacement de votre code Amazon S3, les propriétés de l’application et les paramètres de l’application.

À un niveau élevé, l’API de table Python est un encapsuleur autour de l’API de table Java. Pour plus d'informations sur l'API Python Table, consultez le didacticiel de l'API Table dans la documentation Apache Flink.