Anwendungscode - Amazon-Kinesis-Data-Analytics für SQL-Anwendungen

Für neue Projekte empfehlen wir, den neuen Managed Service für Apache Flink Studio anstelle von Kinesis-Data-Analytics-for-SQL-Anwendungen 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.

Anwendungscode

Der Anwendungscode besteht aus einer Reihe von SQL-Anweisungen, die Eingabedaten verarbeiten und Ausgabedaten erzeugen. Diese SQL-Anweisungen verarbeiten In-Application-Streams und Referenztabellen. Weitere Informationen finden Sie unter Amazon Kinesis Data Analytics für SQL-Anwendungen: So funktioniert's.

Weitere Informationen zu den SQL-Sprachelementen, die von Kinesis Data Analytics unterstützt werden, finden Sie in der Amazon Kinesis Data Analytics-SQL-Referenz.

In relationalen Datenbanken arbeiten Sie mit Tabellen und verwenden dabei INSERT-Anweisungen, um Datensätze und die SELECT-Anweisung zur Abfrage der Daten hinzuzufügen. In Amazon Kinesis Data Analytics arbeiten Sie mit Streams. Sie können eine SQL-Anweisung zur Abfrage dieser Streams schreiben. Die Ergebnisse der Abfrage eines In-Application-Streams werden stets an einen anderen In-Application-Stream gesendet. Bei der Ausführung komplexer Analysen können Sie mehrere In-Application-Streams erstellen, die die Ergebnisse zwischengeschalteter Analysen enthalten. Und schließlich können Sie die Anwendungsausgabe so konfigurieren, dass die Ergebnisse der letzten Analyse (aus einem oder mehreren In-Application-Streams) an externe Ziele weitergeleitet werden. Zusammenfassend kann gesagt werden, dass das folgende Muster für das Schreiben von Anwendungs-Code typisch ist:

  • Die SELECT-Anweisung wird stets im Zusammenhang mit einer INSERT-Anweisung verwendet. Das bedeutet, dass Sie Ergebnisse in einen anderen In-Application-Stream einfügen, wenn Sie Zeilen auswählen.

  • Die INSERT-Anweisung wird stets im Zusammenhang mit einer Pump verwendet. Das bedeutet, dass Sie Pumps verwenden, um zu einem In-Application-Stream zu schreiben.

Das folgende Beispiel für einen Anwendungs-Code liest Datensätze aus einem In-Application-Stream (SOURCE_SQL_STREAM_001) und schreibt diese zu einem anderen In-Application-Stream (DESTINATION_SQL_STREAM). Sie können Datensätze mittels Pumps in In-Application-Streams einfügen, wie im Folgenden gezeigt:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   change DOUBLE, 
                                                   price DOUBLE);
-- Create a pump and insert into output stream.
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 

  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM ticker_symbol, change,price
    FROM   "SOURCE_SQL_STREAM_001";
Anmerkung

Die Kennungen, die Sie für Stream- und Spaltennamen angeben, folgen SQL-Standardkonventionen. Wenn Sie beispielsweise eine Kennung in Anführungszeichen setzen, wird bei der Kennung zwischen Groß- und Kleinschreibung unterschieden. Wenn Sie keine Anführungszeichen setzen, werden für die Kennung standardmäßig Großbuchstaben verwendet. Weitere Informationen zu Identifikatoren finden Sie unter Identifikatoren in der Amazon Managed Service für Apache Flink-SQL-Referenz.

Ihr Anwendungs-Code kann aus zahlreichen SQL-Anweisungen bestehen. Beispiele:

  • Sie können SQL-Abfragen sequenziell schreiben, sodass das Ergebnis einer SQL-Anweisung für die nächste SQL-Anweisung verwendet wird.

  • Sie können auch SQL-Abfragen schreiben, die unabhängig voneinander ausgeführt werden. Sie können beispielsweise zwei SQL-Anweisungen schreiben, die denselben In-Application-Stream abfragen, die Ausgabe jedoch an verschiedene In-Application-Streams senden. Anschließend können Sie die neu erstellten In-Application-Streams unabhängig voneinander abfragen.

Sie können In-Application-Streams erstellen, um Zwischenergebnisse zu speichern. Sie fügen Daten mittels Pumpen in In-Application-Streams ein. Weitere Informationen finden Sie unter In-Application-Streams und Pumps.

Wenn Sie eine In-Application-Referenztabelle hinzufügen, können Sie SQL schreiben, um Daten in In-Application-Streams und Referenztabellen zusammenzuführen. Weitere Informationen finden Sie unter Beispiel: Hinzufügen von Referenzdaten zu einer Kinesis Data Analytics-Anwendung.

Amazon Kinesis Data Analytics schreibt Daten entsprechend der Ausgabekonfiguration der Anwendung aus bestimmten In-Application-Streams zum externen Ziel. Stellen Sie sicher, dass Ihr Anwendungs-Code zu den In-Application-Streams schreibt, die in der Ausgabekonfiguration angegeben sind.

Weitere Informationen finden Sie unter den folgenden Themen: