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

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

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.

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.

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

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:

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

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.

   

   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.