Nach reiflicher Überlegung haben wir beschlossen, Amazon Kinesis Data Analytics für SQL Anwendungen in zwei Schritten einzustellen:
1. Ab dem 15. Oktober 2025 können Sie keine neuen Kinesis Data Analytics für SQL Anwendungen erstellen.
2. Wir werden Ihre Anwendungen ab dem 27. Januar 2026 löschen. Sie können Ihre Amazon Kinesis Data Analytics for SQL Applications weder starten noch betreiben. SQLAb diesem Zeitpunkt ist kein Support mehr für Amazon Kinesis Data Analytics verfügbar. Weitere Informationen finden Sie unter Einstellung von Amazon Kinesis Data Analytics for SQL Applications.
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.4: (Optional) Aktualisieren des Anwendungscodes
In diesem Schritt erfahren Sie, wie Sie den Anwendungscode aktualisieren.
So aktualisieren Sie den Anwendungscode
-
Erstellen Sie wie folgt einen anderen In-Application-Stream:
-
Erstellen Sie einen anderen In-Application-Stream mit der Bezeichnung
DESTINATION_SQL_STREAM_2
. -
Erstellen Sie eine Pump und verwenden Sie diese anschließend, um durch Auswahl von Zeilen aus
DESTINATION_SQL_STREAM
Zeilen in den neu erstellten Stream einzufügen.
Fügen Sie im SQL Editor den folgenden Code an den vorhandenen Anwendungscode an:
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS INSERT INTO "DESTINATION_SQL_STREAM_2" SELECT STREAM ticker_symbol, change, price FROM "DESTINATION_SQL_STREAM";
Speichern Sie den Code und führen Sie ihn aus. Zusätzliche In-Application-Streams werden auf der Registerkarte Real-time analytics angezeigt.
-
-
Erstellen Sie zwei In-Application-Streams. Filtern Sie Zeilen in
SOURCE_SQL_STREAM_001
basierend auf dem Börsenticker und fügen Sie sie in diese separaten Streams ein.Hängen Sie die folgenden SQL Anweisungen an Ihren Anwendungscode an:
CREATE OR REPLACE STREAM "AMZN_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "AMZN_PUMP" AS INSERT INTO "AMZN_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%AMZN%'; CREATE OR REPLACE STREAM "TGT_STREAM" (ticker_symbol VARCHAR(4), change DOUBLE, price DOUBLE); CREATE OR REPLACE PUMP "TGT_PUMP" AS INSERT INTO "TGT_STREAM" SELECT STREAM ticker_symbol, change, price FROM "SOURCE_SQL_STREAM_001" WHERE ticker_symbol SIMILAR TO '%TGT%';
Speichern Sie den Code und führen Sie ihn aus. Beachten Sie die zusätzlichen In-Application-Streams auf der Registerkarte Real-time analytics.
Sie haben nun Ihre erste funktionierende Amazon-Kinesis-Data-Analytics-Anwendung. In dieser Übung haben Sie folgende Aufgaben ausgeführt:
-
Sie haben Ihre erste Kinesis Data Analytics-Anwendung erstellt.
-
Sie haben die Anwendungseingabe konfiguriert, die den Demo-Stream als Streaming-Quelle identifiziert und einem erstellten In-Application-Stream (
SOURCE_SQL_STREAM_001
) zugewiesen hat. Kinesis Data Analytics liest den Demo-Stream kontinuierlich und fügt Datensätze in den In-Application-Stream ein. -
Ihr Anwendungscode hat
SOURCE_SQL_STREAM_001
abgefragt und die Ausgabe in einen anderen In-Application-Stream mit der BezeichnungDESTINATION_SQL_STREAM
geschrieben.
Jetzt können Sie optional die Anwendungsausgabe konfigurieren, um die Ausgabe in ein externes Ziel zu schreiben. Sie können also die Anwendungsausgabe so konfigurieren, dass Datensätze in DESTINATION_SQL_STREAM
in ein externes Ziel geschrieben werden. In dieser Übung ist dies ein optionaler Schritt. Um zu erfahren, wie Sie das Ziel konfigurieren, gehen Sie weiter zum nächsten Schritt.
Nächster Schritt
Schritt 4 (optional) Bearbeiten Sie das Schema und den SQL Code mithilfe der Konsole.