Schritt 3: Erstellen Ihrer Amazon-Kinesis-Data-Analytics-Startanwendung - Entwicklerhandbuch für Amazon Kinesis Data Analytics for SQL Applications

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: Erstellen Ihrer Amazon-Kinesis-Data-Analytics-Startanwendung

Wenn Sie die Schritte in diesem Abschnitt durchführen, können Sie Ihre erste Kinesis Data Analytics-Anwendung mithilfe der Konsole erstellen.

Anmerkung

Wir empfehlen, den Abschnitt Amazon Kinesis Data Analytics für SQL-Anwendungen: So funktioniert's noch einmal zu lesen, bevor Sie die Einstiegsübung absolvieren.

Für diese Einstiegsübung können Sie die Konsole verwenden, um entweder mit dem Demo-Stream oder Vorlagen mit Anwendungs-Code zu arbeiten.

  • Wenn Sie den Demo-Stream verwenden, erstellt die Konsole einen Kinesis-Datenstrom mit der Bezeichnung kinesis-analytics-demo-stream in Ihrem Konto.

    Eine Kinesis Data Analytics-Anwendung erfordert eine Streaming-Quelle. Für diese Quelle verwenden mehrere SQL Beispiele in diesem Handbuch den Demo-Streamkinesis-analytics-demo-stream. Die Konsole führt darüber hinaus ein Skript aus, das dem Stream kontinuierlich Beispieldaten (simulierte Aktienhandelsdatensätze) hinzufügt, wie im Folgenden gezeigt.

    Formatierte Stream-Beispiel-Tabelle mit Aktiensymbolen, Sektoren und Preisen.

    In dieser Übung können Sie kinesis-analytics-demo-stream als Streaming-Quelle für Ihre Anwendung verwenden.

    Anmerkung

    Der Demo-Stream verbleibt in Ihrem Konto. Sie können ihn verwenden, um andere Beispiele in diesem Handbuch zu testen. Wenn Sie die Konsole jedoch verlassen, beendet das von der Konsole verwendete Skript das Füllen mit Daten. Die Konsole bietet die Option, bei Bedarf erneut mit dem Füllen des Streams zu beginnen.

  • Wenn Sie die Vorlagen mit Beispiel-Anwendungscode verwenden, benutzen Sie den von der Konsole bereitgestellten Vorlagencode, um einfache Analysen auf dem Demo-Stream durchzuführen.

Sie können diese Funktionen verwenden, um Ihre erste Anwendung schnell folgendermaßen einzurichten:

  1. Erstellen Sie eine Anwendung – Sie müssen nur einen Namen vergeben. Die Konsole erstellt die Anwendung und der Service setzt den Anwendungsstatus auf READY.

     

  2. Konfigurieren von Eingaben – Zuerst fügen Sie eine Streaming-Quelle, den Demo-Stream, hinzu. Sie müssen einen Demo-Stream in der Konsole erstellen, bevor Sie diesen verwenden können. Die Konsole leitet dann anhand einer Stichprobe von Datensätzen im Demo-Stream ein Schema für den In-Application-Eingabe-Stream ab, der erstellt wird. Die Konsole benennt den In-Application-Stream mit SOURCE_SQL_STREAM_001.

    Die Konsole verwendet die ErkennungAPI, um das Schema abzuleiten. Falls erforderlich können Sie das abgeleitete Schema bearbeiten. Weitere Informationen finden Sie unter DiscoverInputSchema. Kinesis Data Analytics verwendet dieses Schema zum Erstellen eines In-Application-Streams.

     

    Wenn Sie die Anwendung starten, liest Kinesis Data Analytics den Demo-Stream kontinuierlich in Ihrem Auftrag und fügt Zeilen im In-Application-Eingabe-Stream SOURCE_SQL_STREAM_001 ein.

     

  3. Angeben des Anwendungscodes – Sie verwenden eine Vorlage (mit der Bezeichnung Continuous filter), die den folgenden Code bereitstellt:

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
  (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
 
-- Create pump to insert into output. 
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 sector SIMILAR TO '%TECH%';

    Der Anwendungscode fragt den In-Application-Stream SOURCE_SQL_STREAM_001 ab. Der Code fügt dann mittels Pumps die resultierenden Zeilen in einen anderen In-Application-Stream DESTINATION_SQL_STREAM ein. Weitere Informationen zu diesem Codierungsmuster finden Sie unter Anwendungscode.

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

     

  4. Konfigurieren der Ausgabe – In dieser Übung konfigurieren Sie keine Ausgabe. Das bedeutet, dass Sie keine Daten im In-Application-Stream ablegen, die Ihre Anwendung für ein externes Ziel erstellt. Stattdessen überprüfen Sie Abfrageergebnisse in der Konsole. Weitere Beispiele in diesem Handbuch zeigen, wie die Ausgabe konfiguriert wird. Ein Beispiel finden Sie unter Beispiel: Erstellen einfacher Warnungen.

Wichtig

In dieser Übung wird die Region USA Ost (Nord-Virginia) (us-east-1) zum Einrichten der Anwendung verwendet. Sie können jedes der unterstützten verwenden AWS-Regionen.

Nächster Schritt

Schritt 3.1: Eine Anwendung erstellen