Erste Schritte mit HAQM Managed Service für Apache Flink
Warum HAQM Managed Service für Apache Flink?
Mit HAQM Managed Service für Apache Flink können Sie Streaming-Daten mit Apache Flink in Echtzeit umwandeln und analysieren. HAQM Managed Service für Apache Flink vereinfacht die Entwicklung und Verwaltung von Apache-Flink-Workloads und ermöglicht Ihnen die Integration von Anwendungen mit anderen AWS-Services.
Erstellen von Streaming-Anwendungen mit Apache Flink und Apache Beam
1
Schritt 1: Laden Sie die Open-Source-Bibliotheken in Ihre bevorzugte IDE herunter
Sie können damit beginnen, die Open-Source-Bibliotheken herunterzuladen, darunter das AWS-SDK, Apache Flink und Konnektoren für AWS-Services.
2
Schritt 2: Erstellen Sie eine Beispielanwendung mit Apache Flink oder Apache Beam
Sie schreiben Ihren Apache Flink-Anwendungscode mit Daten-Streams und Stream-Operatoren. Die Anwendungs-Daten-Streams sind die Datenstruktur, gegenüber der Sie die Verarbeitung mit Ihrem Anwendungscode durchführen. Die Daten fließen kontinuierlich von den Quellen in die Anwendungs-Daten-Streams. Ein oder mehrere Stream-Operatoren werden verwendet, um Ihre Verarbeitung des Anwendungs-Datenströme zu definieren.
3
Schritt 3: Laden Sie Ihren Code für Apache Flink in HAQM Managed Service hoch
Laden Sie Ihren Code nach der Erstellung auf HAQM Managed Service für Apache Flink hoch. Der Service kümmert sich um alles, was für die kontinuierliche Ausführung Ihrer Echtzeit-Anwendungen erforderlich ist. Außerdem passt es sich automatisch an den Umfang und den Durchsatz Ihrer eingehenden Daten an.
Intuitive Nutzung des HAQM Managed Service für Apache Flink Studio
1
Schritt 1: Erstellen Sie eine Anwendung für HAQM Managed Service für Apache Flink Studio
Starten Sie über die Konsole von HAQM Managed Service für Apache Flink, HAQM MSK oder HAQM Kinesis Data Streams. Verwenden Sie benutzerdefinierte Konnektoren, um eine Verbindung zu jeder anderen Datenquelle herzustellen.
2
Schritt 2: Schreiben Sie Code im Serverless-Notebook in SQL, Python und Scala und erstellen Sie Apache-Flink-Anwendungen
Führen Sie einzelne Abschnitte im Notebook aus, zeigen Sie die Ergebnisse im Kontext an und verwenden Sie die integrierte Visualisierung von Apache Zeppelin, um die Entwicklung zu beschleunigen. Sie können auch benutzerdefinierte Funktionen in Ihrem Code verwenden.
3
Schritt 3: Streaming-Anwendung von HAQM Managed Service für Apache Flink erstellen und bereitstellen
Stellen Sie Ihren Code in nur wenigen Schritten als kontinuierlich laufende Anwendung zur Stream-Verarbeitung bereit. Bei Ihrer bereitgestellten Anwendung handelt es sich um eine Anwendung von HAQM Managed Service für Apache Flink mit dauerhaftem Status und Auto Scaling. Sie haben auch die Möglichkeit, Quellen, Ziele, Protokollierungs- und Überwachungsebenen zu ändern, bevor Sie Ihren Code in Produktion geben.