Schritt 3.3: Hinzufügen von Echtzeit-Analysen (Hinzufügen von Anwendungscode) - 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.

Schritt 3.3: Hinzufügen von Echtzeit-Analysen (Hinzufügen von Anwendungscode)

Sie können Ihre eigenen SQL Abfragen für den anwendungsinternen Stream schreiben, aber für den folgenden Schritt verwenden Sie eine der Vorlagen, die Beispielcode enthält.

  1. Wählen Sie auf der Seite des Anwendungs-Hubs die Option Gehe zum SQL Editor aus.

    Screenshot der Beispielanwendungsseite mit der Schaltfläche „Gehe zum SQL Editor“.

  2. Im Feld Möchten Sie mit dem Ausführen von "ExampleApp„beginnen? Wählen Sie im Dialogfeld Ja, Anwendung starten aus.

    Die Konsole sendet eine Anfrage zum Starten der Anwendung (sieheStartApplication), und dann wird die SQL Editor-Seite angezeigt.

  3. Die Konsole öffnet die SQL Editor-Seite. Sehen Sie sich die Seite an, einschließlich der Schaltflächen (SQLAus Vorlagen hinzufügen, Speichern und Ausführen SQL) und der verschiedenen Registerkarten.

  4. Wählen Sie im SQL Editor „SQLAus Vorlagen hinzufügen“.

  5. Wählen Sie in der Liste der verfügbaren Vorlagen Continuous filter aus. Der Beispiel-Code liest Daten aus einem In-Application-Stream (über die WHERE-Klausel werden die Zeilen gefiltert) und fügt sie wie folgt in einen anderen In-Application-Stream ein:

    • Der In-Application-Stream DESTINATION_SQL_STREAM wird erstellt.

    • Es wird das Pump STREAM_PUMPerstellt, diese wird zur Auswahl von Zeilen aus SOURCE_SQL_STREAM_001 verwendet, die dann in DESTINATION_SQL_STREAM eingefügt werden.

  6. Wählen Sie „Zum Editor SQL hinzufügen“.

  7. Testen Sie den Anwendungscode wie folgt:

    Denken Sie daran, dass Sie die Anwendung bereits gestartet haben (Status istRUNNING). Daher ist Amazon-Kinesis-Data-Analytics bereits kontinuierlich dabei, Daten aus der Streaming-Quelle zu lesen und Zeilen zum In-Application-Stream SOURCE_SQL_STREAM_001 hinzuzufügen.

    1. Wählen Sie im SQL Editor Speichern und ausführen SQL. Die Konsole sendet zunächst eine Aktualisierungsanforderung, um den Anwendungscode zu speichern. Anschließend wird der Code kontinuierlich ausgeführt.

    2. Die Ergebnisse können Sie auf der Registerkarte Real-time analytics sehen.

      Screenshot des SQL Editors mit Ergebnissen, die auf der Registerkarte „Echtzeitanalysen“ angezeigt werden.

      Der SQL Editor hat die folgenden Tabs:

      • Auf der Registerkarte Source data wird ein In-Application-Eingabe-Stream angezeigt, welcher der Streaming-Quelle zugeordnet ist. Wenn Sie den In-Application-Stream auswählen, können Sie sehen, dass Daten ankommen. Beachten Sie die zusätzlichen Spalten im In-Application-Eingabe-Stream, die nicht in den Eingabekonfiguration angegeben wurden. Hierzu gehören die folgenden Zeitstempelspalten:

         

        • ROWTIME— Jede Zeile in einem In-Application-Stream hat eine spezielle Spalte namensROWTIME. Diese Spalte ist der Zeitstempel, also der Zeitpunkt, an dem Amazon-Kinesis-Data-Analytics die Zeile in den ersten In-Application-Stream (den In-Application-Eingabe-Stream, welcher der Streaming-Quelle zugeordnet ist) eingefügt hat.

           

        • Approximate_Arrival_Time – Jeder Kinesis Data Analytics-Datensatz enthält einen Wert mit der Bezeichnung Approximate_Arrival_Time. Dieser wird ist der Zeitstempel für das ungefähre Eintreffen, der gesetzt wird, wenn die Streaming-Quelle den entsprechenden Datensatz erfolgreich erhält und speichert. Wenn Kinesis Data Analytics Datensätze aus einer Streaming-Quelle liest, wird diese Spalte in den In-Application-Eingabe-Stream abgerufen.

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

         

      • Auf der Registerkarte Real-time analytics werden alle anderen In-Application-Streams angezeigt, die von Ihrem Anwendungscode erstellt wurden. Auch der Fehler-Stream ist hier enthalten. Kinesis Data Analytics sendet alle Zeilen, die nicht verarbeitet werden können, in den Fehler-Stream. Weitere Informationen finden Sie unter Fehlerbehandlung.

         

        Wählen Sie DESTINATION_SQL_STREAM aus, um die von Ihrem Anwendungscode eingefügten Zeilen anzuzeigen. Beachten Sie auch hier die zusätzlichen Spalten, die nicht von Ihrem Anwendungscode erstellt wurden. Diese Spalten beinhalten die Zeitstempelspalte ROWTIME. Kinesis Data Analytics kopiert diese Werte einfach aus der Quelle (SOURCE_SQL_STREAM_001).

         

      • Auf der Registerkarte Ziel wird das externe Ziel angezeigt, in das Kinesis Data Analytics die Abfrageergebnisse schreibt. Sie haben noch kein externes Ziel für Ihre Anwendungsausgabe konfiguriert.

Nächster Schritt

Schritt 3.4: (Optional) Aktualisieren des Anwendungscodes