Créez votre service géré pour l'application Apache Flink Python - Service géré pour Apache Flink
Spécifiez vos fichiers de code

Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics 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.

Créez votre service géré pour l'application Apache Flink Python

Spécifiez vos fichiers de code

Une fois que vous avez créé le package de code de votre application, vous le chargez dans un compartiment Amazon S3. Vous créez ensuite votre application à l'aide de la console ou de l'CreateApplicationaction.

Lorsque vous créez votre application à l'aide de cette CreateApplicationaction, vous spécifiez les fichiers de code et les archives de votre fichier zip à l'aide d'un groupe de propriétés d'application spécial appelékinesis.analytics.flink.run.options. Vous pouvez définir les types de fichiers suivants :

  • python : fichier texte contenant une méthode principale de Python.

  • jarfile : JAR fichier Java contenant des fonctions Java définies par l'utilisateur.

  • pyFiles: fichier de ressources Python contenant les ressources à utiliser par l'application.

  • pyArchives: fichier zip contenant les fichiers de ressources de l'application.

Pour plus d'informations sur les types de fichiers de code Python d'Apache Flink, consultez la section Interface de ligne de commande dans la documentation d'Apache Flink.

Note

Le service géré pour Apache Flink ne prend pas en charge les types de fichiers pyModule, pyExecutable ou pyRequirements. L’ensemble du code, des exigences et des dépendances doivent se trouver dans votre fichier zip. Vous ne pouvez pas spécifier les dépendances à installer à l’aide de pip.

L’exemple d’extrait de code JSON suivant montre comment spécifier l’emplacement des fichiers dans le fichier zip de votre application :

"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"
          }
        },