Beispiel: Erstellen einfacher Warnungen

PDFRSS

In dieser Kinesis Data Analytics-Anwendung wird die Abfrage kontinuierlich im In-Application-Stream ausgeführt, der über dem Demo-Stream erstellt wird. Weitere Informationen finden Sie unter Kontinuierliche Abfragen.

Wenn Zeilen eine Änderung des Aktienpreises um mehr als 1 % zeigen, werden diese Zeilen in einen anderen In-Application-Stream eingefügt. In der Übung können Sie die Anwendungsausgabe für die Weiterleitung der Ergebnisse an ein externes Ziel konfigurieren. Sie können die Ergebnisse anschließend weiter untersuchen. Sie können beispielsweise eine AWS Lambda Funktion verwenden, um Datensätze zu verarbeiten und Ihnen Benachrichtigungen zu senden.

So erstellen Sie eine Anwendung für einfache Warnungen

1. Erstellen Sie die Analyseanwendung wie in der Übung unter Erste Schritte für Kinesis Data Analytics beschrieben.

2. Ersetzen Sie im SQL-Editor in Kinesis Data Analytics den Anwendungscode durch Folgendes:

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
              (ticker_symbol VARCHAR(4), 
               sector        VARCHAR(12), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
      INSERT INTO "DESTINATION_SQL_STREAM"
         SELECT STREAM ticker_symbol, sector, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  (ABS(Change / (Price - Change)) * 100) > 1;

   Die SELECT-Anweisung im Anwendungscode filtert Zeilen im SOURCE_SQL_STREAM_001 nach Aktienpreisänderungen von mehr als 1 %. Sie fügt diese Zeilen dann mittels eines Pump in einen anderen DESTINATION_SQL_STREAM-In-Application-Stream ein. Weitere Informationen zum Kodierungsmuster, das die Verwendung von Pumps zum Einfügen von Zeilen in In-Application-Streams beschreibt, finden Sie unter Anwendungscode.

3. Klicken Sie auf Save and run SQL (SQL speichern und ausführen).

4. Fügen Sie ein Ziel hinzu. Zu diesem Zweck wählen Sie entweder die Registerkarte Destination (Ziel) im SQL-Editor oder Add a destination (Ziel hinzufügen) auf der Detailseite der Anwendung.

   1. Wählen Sie im SQL-Editor die Registerkarte Destination (Ziel) und danach Connect to a destination (Mit einem Ziel verbinden).

      Klicken Sie auf der Seite Connect to destination (Mit Ziel verbinden) auf Create New (Neu erstellen).

   2. Wählen Sie Go to Kinesis Streams.

   3. Erstellen Sie in der Amazon-Kinesis-Data-Streams -Konsole einen neuen Kinesis Stream (z. B. gs-destination) mit einer Shard. Warten Sie, bis der Status des Streams ACTIVE ist.

   4. Kehren Sie zur Kinesis Data Analytics-Konsole zurück. Wählen Sie auf der Seite Connect to destination (Mit Ziel verbinden) den von Ihnen erstellten Stream aus.

      Wenn der Stream nicht angezeigt wird, aktualisieren Sie die Seite.

   5. Wählen Sie Save and continue aus.

   Sie besitzen nun ein externes Ziel, einen Kinesis-Datenstrom, an dem Kinesis Data Analytics die Ausgabe Ihrer Anwendung im In-App-DESTINATION_SQL_STREAM-Stream beibehält.

5. Konfigurieren Sie die Konfiguration AWS Lambda , um den von Ihnen erstellten Kinesis-Stream zu überwachen und eine Lambda-Funktion aufzurufen.

   Detaillierte Anweisungen finden Sie unter Vorverarbeitung von Daten mithilfe einer Lambda-Funktion.