Amazon Managed Service for Apache Flink (Amazon MSF) war zuvor als Amazon Kinesis Data Analytics for 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 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
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 Mavenpom.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 die 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 (Amazon MSF) -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 der DataStream API in Managed Service für Apache Flink Tutorial.
Erstellen Sie Ihre Managed Service for Apache Flink-Anwendung: Verwenden Sie eine der folgenden Methoden, um Ihre Amazon MSF-Anwendung zu erstellen:
Anmerkung
Amazon MSF verschlüsselt Ihre Anwendung standardmäßig mit. AWS-eigene Schlüssel Sie können Ihre neue Anwendung auch mithilfe von vom AWS KMS Kunden verwalteten Schlüsseln (CMKs) erstellen, um Ihre Schlüssel selbst zu erstellen, zu besitzen und zu verwalten. Informationen zu finden CMKs Sie unterSchlüsselverwaltung in Amazon Managed Service für Apache Flink.
Erstellen Sie Ihre Amazon MSF-Anwendung mit 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 der DataStream API in Managed Service für Apache Flink Tutorial.
Erstellen Sie Ihre Amazon MSF-Anwendung mit der AWS CLI: Sie können Ihre Anwendung mithilfe der AWS CLI erstellen und konfigurieren.
Wenn Sie Ihre Anwendung mithilfe der CLI erstellen, 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 der CLI erstellen, geben Sie mithilfe des
RuntimeEnvironment-Aktionsparameters derCreateApplication-Aktion an, welche Version von Apache Flink Ihre Anwendung verwendet.
Anmerkung
Sie können die
RuntimeEnvironmenteiner vorhandenen Anwendung ändern. Um zu erfahren wie dies geht, vgl. Verwenden Sie direkte Versionsupgrades für Apache Flink.
Verwenden Sie vom Kunden verwaltete Schlüssel
In Amazon MSF sind vom Kunden verwaltete Schlüssel (CMKs) eine Funktion, mit der Sie die Daten Ihrer Anwendung mit einem Schlüssel verschlüsseln können, den Sie auf AWS Key Management Service (AWS KMS) erstellen, besitzen und verwalten. Für eine Amazon MSF-Anwendung bedeutet dies, dass alle Daten, die einem Flink-Checkpoint oder -Snapshot unterliegen, mit einem CMK verschlüsselt werden, den Sie für diese Anwendung definieren.
Um CMK mit Ihrer Anwendung zu verwenden, müssen Sie zuerst Ihre neue Anwendung erstellen und dann eine CMK anwenden. Weitere Informationen zur Verwendung CMKs finden Sie unter. Schlüsselverwaltung in Amazon Managed Service 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 mithilfe 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: Mithilfe von CloudWatch Logs and CloudWatch Logs Insights können Sie ü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.
