Erstellen Sie einen Managed Service für die Apache Flink-Anwendung

Dieses Thema enthält Informationen zum Erstellen einer Managed Service für Apache Flink-Anwendung.

Dieses Thema enthält die folgenden Abschnitte:

• Erstellen Sie Ihren Anwendungscode für Managed Service für Apache Flink
• Erstellen Sie Ihre Managed Service für Apache Flink-Anwendung
• Starten Sie Ihre Managed Service for Apache Flink-Anwendung
• Überprüfen Sie Ihre Anwendung Managed Service für Apache Flink
• Aktivieren Sie System-Rollbacks für Ihre Managed Service for Apache Flink-Anwendung

Erstellen Sie Ihren Anwendungscode für Managed Service für Apache Flink

In diesem Abschnitt werden die Komponenten beschrieben, mit denen Sie den Anwendungscode für Ihre Managed Service for Apache Flink-Anwendung erstellen.

Es wird empfohlen, die neueste unterstützte Version von Apache Flink für Ihren Anwendungscode zu verwenden. Informationen zur Aktualisierung von Managed Service für Apache Flink-Anwendungen finden Sie unter Verwenden Sie direkte Versionsupgrades für Apache Flink.

Sie erstellen Ihren Anwendungscode mit Apache Maven. Ein Apache Maven-Projekt verwendet eine pom.xml-Datei, um die Versionen der verwendeten Komponenten anzugeben.

Anmerkung

Managed Service für Apache Flink unterstützt JAR Dateien mit einer Größe von bis zu 512 MB. Wenn Sie eine größere JAR Datei verwenden, kann Ihre Anwendung nicht gestartet werden.

Anwendungen können jetzt Java API von jeder Scala-Version aus verwenden. Sie müssen die Scala-Standardbibliothek Ihrer Wahl in Ihre Scala-Anwendungen integrieren.

Informationen zum Erstellen einer Managed-Service-für-Apache-Flink-Anwendung, die Apache Beam verwendet, finden Sie unter Verwenden Sie Apache Beam mit Managed Service für Apache Flink-Anwendungen.

Geben Sie die Apache Flink-Version Ihrer Anwendung an

Wenn Sie Managed Service für Apache Flink Laufzeit Version 1.1.0 und höher verwenden, geben Sie die Version von Apache Flink an, die Ihre Anwendung verwendet, wenn Sie Ihre Anwendung kompilieren. Sie geben die Version von Apache Flink mit dem Parameter an-Dflink.version. Wenn Sie beispielsweise Apache Flink 1.19.1 verwenden, geben Sie Folgendes an:

mvn package -Dflink.version=1.19.1

Informationen zum Erstellen von Anwendungen mit früheren Versionen von Apache Flink finden Sie unter. Frühere Versionen

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

Nachdem Sie Ihren Anwendungscode erstellt haben, gehen Sie wie folgt vor, um Ihre Managed Service for Apache Flink-Anwendung zu erstellen:

• Laden Sie Ihren Anwendungscode hoch: Laden Sie Ihren Anwendungscode in einen Amazon-S3-Bucket hoch. Geben Sie beim Erstellen Ihrer Anwendung den S3-Bucket-Namen und den Objektnamen Ihres Anwendungscodes an. Ein Tutorial, das zeigt, wie Sie Ihren Anwendungscode hochladen, finden Sie im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

• Erstellen Sie Ihre Managed Service für Apache Flink-Anwendung: Verwenden Sie eine der folgenden Methoden, um Ihre Managed Service für Apache Flink-Anwendung zu erstellen:

  • Erstellen Sie Ihre Managed Service for Apache Flink-Anwendung mithilfe der AWS Konsole: Sie können Ihre Anwendung mithilfe der AWS Konsole erstellen und konfigurieren.

    Wenn Sie Ihre Anwendung mithilfe der Konsole erstellen, werden die von Ihrer Anwendung abhängigen Ressourcen (wie CloudWatch Log-Streams, IAM Rollen und IAM Richtlinien) für Sie erstellt.

    Wenn Sie die Anwendung mithilfe der Konsole erstellen, geben Sie an, welche Version von Apache Flink Ihre Anwendung verwendet, indem Sie sie aus dem Pulldown-Menü auf der Seite Managed– Service für Apache Flink Anwendung erstellen auswählen.

    Ein Tutorial zur Verwendung der Konsole zum Erstellen einer Anwendung finden Sie im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

  • Erstellen Sie Ihre Managed Service for Apache Flink-Anwendung mit dem AWS CLI: Sie können Ihre Anwendung mit dem AWS CLI erstellen und konfigurieren.

    Wenn Sie Ihre Anwendung mit dem erstellenCLI, müssen Sie auch die abhängigen Ressourcen Ihrer Anwendung (wie CloudWatch Log-Streams, IAM Rollen und IAM Richtlinien) manuell erstellen.

    Wenn Sie Ihre Anwendung mit dem erstellenCLI, geben Sie mithilfe des RuntimeEnvironment CreateApplication Aktionsparameters an, welche Version von Apache Flink Ihre Anwendung verwendet.

  Anmerkung

  Sie können die RuntimeEnvironment einer vorhandenen Anwendung ändern. Um zu erfahren wie dies geht, vgl. Verwenden Sie direkte Versionsupgrades für Apache Flink.

Starten Sie Ihre Managed Service for Apache Flink-Anwendung

Nachdem Sie Ihren Anwendungscode erstellt, in S3 hochgeladen und Ihre Managed Service für Apache Flink-Anwendung erstellt haben, starten Sie die Anwendung. Das Starten einer Anwendung Managed Service für Apache Flink dauert in der Regel mehrere Minuten.

Verwenden Sie eine der folgenden Methoden, um die Anwendung zu starten:

• Starten Sie Ihre Managed Service for Apache Flink-Anwendung über die AWS Konsole: Sie können Ihre Anwendung ausführen, indem Sie auf der Seite Ihrer Anwendung in der AWS Konsole auf Ausführen klicken.

• Starten Sie Ihre Managed Service for Apache Flink-Anwendung mit der AWS API: Sie können Ihre Anwendung mithilfe der StartApplicationAktion ausführen.

Überprüfen Sie Ihre Anwendung Managed Service für Apache Flink

Sie können auf folgende Arten überprüfen, ob die Anwendung funktioniert:

• Verwendung von CloudWatch Protokollen: Sie können CloudWatch Logs and CloudWatch Logs Insights verwenden, um zu überprüfen, ob Ihre Anwendung ordnungsgemäß ausgeführt wird. Informationen zur Verwendung von CloudWatch Logs mit Ihrer Managed Service for Apache Flink-Anwendung finden Sie unterProtokollierung und Überwachung in Amazon Managed Service für Apache Flink.

• Verwenden von CloudWatch Metriken: Sie können CloudWatch Metriken verwenden, um die Aktivität Ihrer Anwendung oder die Aktivitäten in den Ressourcen zu überwachen, die Ihre Anwendung für die Eingabe oder Ausgabe verwendet (wie Kinesis-Streams, Firehose-Streams oder Amazon S3 S3-Buckets). Weitere Informationen zu CloudWatch Metriken finden Sie unter Arbeiten mit Metriken im CloudWatch Amazon-Benutzerhandbuch.

• Überwachung der Ausgabespeicherorte: Wenn Ihre Anwendung die Ausgabe an einen Speicherort schreibt (z. B. einen Amazon S3-Bucket oder eine Datenbank), können Sie diesen Speicherort auf geschriebene Daten überwachen.