Arbeiten mit dem SQL-Editor - Entwicklerhandbuch für Amazon Kinesis Data Analytics for SQL Applications

Für neue Projekte empfehlen wir, den neuen Managed Service für Apache Flink Studio anstelle von Kinesis Data Analytics for SQL Applications zu verwenden. Der Managed Service für Apache Flink Studio kombiniert Benutzerfreundlichkeit mit fortschrittlichen Analysefunktionen, sodass Sie in wenigen Minuten anspruchsvolle Anwendungen zur Stream-Verarbeitung erstellen können.

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.

Arbeiten mit dem SQL-Editor

Im Folgenden finden Sie Informationen zu Abschnitten im SQL-Editor und dazu, wie diese jeweils funktionieren. Sie können im SQL-Editor entweder eigenen Code erstellen oder Add SQL from templates wählen. Eine SQL-Vorlage stellt Ihnen SQL-Beispiel-Code bereit, der Sie beim Schreiben gängiger Amazon-Kinesis-Data-Analytics-Anwendungen unterstützen kann. Die Beispielanwendungen in diesem Handbuch verwenden einige dieser Vorlagen. Weitere Informationen finden Sie unter Kinesis Data Analytics für SQL.

Screenshot des SQL-Editors mit der Registerkarte "Real-Time Analytics (Echtzeitanalysen)" und In-Application-Streams.

Registerkarte „Source Data“

Die Registerkarte Source data identifiziert eine Streaming-Quelle. Sie identifiziert auch den In-Application-Eingabe-Stream, dem diese Quelle zugeordnet ist und der die Eingabekonfiguration der Anwendung bereitstellt.

Screenshot des SQL-Editors mit der Quelldaten-Registerkarte und hervorgehobener Streaming-Quelle.

Amazon-Kinesis-Data-Analytics stellt die folgenden Zeitstempelspalten bereit, sodass Sie in Ihrer Eingabekonfiguration keine explizite Zuweisung bereitstellen müssen:

  • ROWTIME – In jeder Zeile in einem In-Application-Stream gibt es eine spezielle Spalte mit der Bezeichnung ROWTIME. Diese Spalte ist der Zeitstempel für den Zeitpunkt, zu dem Kinesis Data Analytics die Zeile in den ersten In-Application-Stream eingefügt hat.

  • Approximate_Arrival_Time – Datensätze in Ihrer Streaming-Quelle enthalten die Spalte Approximate_Arrival_Timestamp. Dies ist der Zeitstempel für die ungefähre Ankunftszeit, der gesetzt wird, wenn die Streaming-Quelle den entsprechenden Datensatz erfolgreich erhält und speichert. Kinesis Data Analytics ruft diese Spalte in den In-Application-Eingabe-Stream als Approximate_Arrival_Time ab. Amazon-Kinesis-Data-Analytics stellt diese Spalte nur in dem In-Application-Eingabe-Stream bereit, der der Streaming-Quelle zugeordnet ist.

Diese Zeitstempelwerte sind in Abfragen mit Zeitfenstern hilfreich. Weitere Informationen finden Sie unter Abfragen mit Fenstern.

Registerkarte „Real-Time Analytics“

Auf der Registerkarte Real-time analytics werden alle In-Application-Streams angezeigt, die von Ihrem Anwendungs-Code erstellt werden. Diese Gruppe von Streams enthält den Fehler-Stream (error_stream), den Amazon-Kinesis-Data-Analytics für alle Anwendungen bereitstellt.

Screenshot des SQL-Editors mit der Registerkarte "Real-Time Analytics (Echtzeitanalysen)" und hervorgehobenen In-Application-Streams.

Registerkarte „Destination“

Über die Registerkarte Zieladresse können Sie die Anwendungsausgabe so konfigurieren, dass sie In-Application-Streams an externe Ziele weiterleitet. Sie können die Ausgabe für die Weiterleitung von Daten aus allen In-Application-Streams an externe Ziele konfigurieren. Weitere Informationen finden Sie unter Konfigurieren der Anwendungsausgabe.