Beispiel: Hinzufügen von Referenzdaten zu einer Kinesis Data Analytics-Anwendung

Öffnen Sie einen Text-Editor, fügen Sie die folgenden Daten hinzu und speichern Sie die Datei als TickerReference.csv.

Ticker, Company
AMZN,Amazon
ASD, SomeCompanyA
MMB, SomeCompanyB
WAS,  SomeCompanyC

Laden Sie die Datei TickerReference.csv in Ihren S3-Bucket hoch. Weitere Anleitungen finden Sie unter Upload eines Objekts zu Amazon S3 im Benutzerhandbuch für Amazon Simple Storage Service.

Erstellen Sie in AWS Identity and Access Management eine IAM-Rolle mit dem Namen KinesisAnalytics-ReadS3Object. Folgen Sie beim Erstellen einer Rolle den Anweisungen unter Erstellen einer Rolle für einen Amazon-Service (AWS Management Console) im IAM-Benutzerhandbuch.

Geben Sie in der IAM-Konsole Folgendes an:

Aktualisieren Sie die IAM-Rollenrichtlinien:

1. Wählen Sie in der IAM-Konsole die von Ihnen erstellte Rolle aus.

2. Aktualisieren Sie auf der Registerkarte Vertrauensstellungen die Vertrauensrichtlinie, um Kinesis Data Analytics die Berechtigung für die Annahme der Rolle zu gewähren. Die Vertrauensrichtlinie wird im Folgenden angezeigt:

   {
     "Version": "2012-10-17",
     "Statement": [
       {
         "Effect": "Allow",
         "Principal": {
           "Service": "kinesisanalytics.amazonaws.com"
         },
         "Action": "sts:AssumeRole"
       }
     ]
   }

3. Fügen Sie auf der Registerkarte Berechtigungen eine von Amazon verwaltete Richtlinie namens AmazonS3ReadOnlyAccess hinzu. Damit gewähren Sie der Rolle Berechtigungen für das Lesen von Amazon S3-Objekten. Diese Richtlinie wird im Folgenden angezeigt:

   {
     "Version": "2012-10-17",
     "Statement": [
       {
         "Effect": "Allow",
         "Action": [
           "s3:Get*",
           "s3:List*"
         ],
         "Resource": "*"
       }
     ]
   }

Wählen Sie auf der Hauptseite der Anwendung Connect reference data (Referenzdaten verbinden) aus.

Wählen Sie auf der Seite Referenzdatenquelle verbinden den Amazon S3 Bucket mit Ihrem Referenzdatenobjekt aus. Geben Sie dann den Schlüsselnamen des Objekts ein.

Geben Sie CompanyName als Namen der In-Application-Referenztabelle ein.

Wählen Sie im Bereich Access to chosen resources (Zugriff auf ausgewählte Ressourcen) die Option Choose from IAM roles that Kinesis Analytics can assume (IAM-Rollen wählen, die Kinesis Analytics annehmen kann). Wählen Sie dann die von Ihnen im vorherigen Abschnitt erstellte IAM-Rolle KinesisAnalytics-ReadS3Object aus.

Klicken Sie auf Discover schema (Schema erkennen). Die Konsole erkennt in den Referenzdaten zwei Spalten.

Klicken Sie auf Save and close.

Ersetzen Sie den Anwendungscode durch den folgenden Code. Die Abfrage führt den In-Application-Eingabe-Stream mit der In-Application-Referenztabelle zusammen. Der Anwendungscode schreibt die Ergebnisse in einen anderen In-Application-Stream, DESTINATION_SQL_STREAM.

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), "Company" varchar(20), sector VARCHAR(12), change DOUBLE, price DOUBLE);

CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
   SELECT STREAM ticker_symbol, "c"."Company", sector, change, price
   FROM "SOURCE_SQL_STREAM_001" LEFT JOIN "CompanyName" as "c"
   ON "SOURCE_SQL_STREAM_001".ticker_symbol = "c"."Ticker";

Überprüfen Sie, ob die Anwendungsausgabe auf der Registerkarte SQLResults angezeigt wird. Stellen Sie sicher, dass einige Zeilen Firmennamen anzeigen (nicht alle Beispielreferenzdaten besitzen Firmennamen).