Erstellen Sie Ihre Python-Anwendung Managed Service für Apache Flink - Managed Service für Apache Flink
Geben Sie Ihre Codedateien an

Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Erstellen Sie Ihre Python-Anwendung Managed Service für Apache Flink

Geben Sie Ihre Codedateien an

Sobald Sie das Codepaket für Ihre Anwendung erstellt haben, laden Sie es in einen Amazon-S3-Bucket hoch. Anschließend erstellen Sie Ihre Anwendung entweder mit der Konsole oder der CreateApplicationAktion.

Wenn Sie Ihre Anwendung mithilfe der CreateApplicationAktion erstellen, geben Sie die Codedateien und Archive in Ihrer ZIP-Datei mithilfe einer speziellen Anwendungseigenschaftengruppe namens ankinesis.analytics.flink.run.options. Sie können die folgenden Dateitypen definieren:

  • python: Eine Textdatei, die eine Python-main-Methode enthält.

  • jarfile: Eine JAR Java-Datei, die benutzerdefinierte Java-Funktionen enthält.

  • pyFiles: Eine Python-Ressourcendatei, die Ressourcen enthält, die von der Anwendung verwendet werden sollen.

  • pyArchives: Eine Zip-Datei mit Ressourcendateien für die Anwendung.

Weitere Informationen zu Apache Flink-Python-Codedateitypen finden Sie unter Command-Line Interface in der Apache Flink-Dokumentation.

Anmerkung

Managed Service für Apache Flink unterstützt nicht die Dateitypen pyModule, pyExecutable oder pyRequirements. Der gesamte Code, die Anforderungen und Abhängigkeiten müssen sich in Ihrer ZIP-Datei befinden. Sie können keine Abhängigkeiten angeben, die mit pip installiert werden sollen.

Der folgende JSON-Beispielausschnitt zeigt, wie Sie Dateispeicherorte in der ZIP-Datei Ihrer Anwendung angeben:

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