Informationen zu früheren Versionen für Managed Service for Apache Flink

1. Stellen Sie sicher, dass Sie Apache Maven installiert haben und dass Ihre JAVA_HOME Umgebungsvariable auf a und JDK nicht auf a verweist. JRE Sie können Ihre Apache Maven-Installation mit dem folgenden Befehl testen:

   mvn -version

2. Laden Sie den Quellcode von Apache Flink Version 1.8.2 herunter:

   wget https://archive.apache.org/dist/flink/flink-1.8.2/flink-1.8.2-src.tgz

3. Dekomprimieren Sie den Apache Flink-Quellcode:

   tar -xvf flink-1.8.2-src.tgz

4. Wechseln Sie in das Apache Flink-Quellcodeverzeichnis:

   cd flink-1.8.2

5. Kompilieren und installieren Sie Apache Flink:

   mvn clean install -Pinclude-kinesis -DskipTests

   Anmerkung

   Wenn Sie Flink unter Microsoft Windows kompilieren, müssen Sie den -Drat.skip=true Parameter hinzufügen.

Um sich für eine anzumelden AWS-Konto

1. Öffnen Sie https://portal.aws.amazon.com/billing/die Anmeldung.

2. Folgen Sie den Online-Anweisungen.

   Bei der Anmeldung müssen Sie auch einen Telefonanruf entgegennehmen und einen Verifizierungscode über die Telefontasten eingeben.

   Wenn Sie sich für eine anmelden AWS-Konto, Root-Benutzer des AWS-Kontoswird eine erstellt. Der Root-Benutzer hat Zugriff auf alle AWS-Services und Ressourcen des Kontos. Als bewährte Sicherheitsmethode weisen Sie einem Administratorbenutzer Administratorzugriff zu und verwenden Sie nur den Root-Benutzer, um Aufgaben auszuführen, die Root-Benutzerzugriff erfordern.

Sichern Sie Ihre Root-Benutzer des AWS-Kontos

1. Melden Sie sich AWS Management Consoleals Kontoinhaber an, indem Sie Root-Benutzer auswählen und Ihre AWS-Konto E-Mail-Adresse eingeben. Geben Sie auf der nächsten Seite Ihr Passwort ein.

   Hilfe bei der Anmeldung mit dem Root-Benutzer finden Sie unter Anmelden als Root-Benutzer im AWS-Anmeldung Benutzerhandbuch zu.

2. Aktivieren Sie die Multi-Faktor-Authentifizierung (MFA) für Ihren Root-Benutzer.

   Anweisungen finden Sie im Benutzerhandbuch unter Aktivieren eines virtuellen MFA Geräts für Ihren AWS-Konto IAM Root-Benutzer (Konsole).

Erstellen eines Benutzers mit Administratorzugriff

1. Aktivieren Sie IAM Identity Center.

   Anweisungen finden Sie unter Aktivieren AWS IAM Identity Center im AWS IAM Identity Center Benutzerhandbuch.

2. Gewähren Sie einem Benutzer in IAM Identity Center Administratorzugriff.

   Ein Tutorial zur Verwendung von IAM-Identity-Center-Verzeichnis als Identitätsquelle finden Sie unter Benutzerzugriff mit der Standardeinstellung konfigurieren IAM-Identity-Center-Verzeichnis im AWS IAM Identity Center Benutzerhandbuch.

Anmelden als Administratorbenutzer

• Um sich mit Ihrem IAM Identity Center-Benutzer anzumelden, verwenden Sie die Anmeldung, URL die an Ihre E-Mail-Adresse gesendet wurde, als Sie den IAM Identity Center-Benutzer erstellt haben.

  Hilfe bei der Anmeldung mit einem IAM Identity Center-Benutzer finden Sie im AWS-Anmeldung Benutzerhandbuch unter Anmeldung beim AWS Zugangsportal.

Weiteren Benutzern Zugriff zuweisen

1. Erstellen Sie in IAM Identity Center einen Berechtigungssatz, der der bewährten Methode zur Anwendung von Berechtigungen mit den geringsten Rechten folgt.

   Anweisungen hierzu finden Sie unter Berechtigungssatz erstellen im AWS IAM Identity Center Benutzerhandbuch.

2. Weisen Sie Benutzer einer Gruppe zu und weisen Sie der Gruppe dann Single Sign-On-Zugriff zu.

   Eine genaue Anleitung finden Sie unter Gruppen hinzufügen im AWS IAM Identity Center Benutzerhandbuch.

Um das einzurichten AWS CLI

1. Herunterladen und Konfigurieren von AWS CLI. Eine Anleitung finden Sie unter den folgenden Themen im AWS Command Line Interface -Benutzerhandbuch:

   • Installieren des AWS Command Line Interface

   • Konfigurieren von AWS CLI

2. Fügen Sie der Datei ein benanntes Profil für den Administratorbenutzer AWS CLI config hinzu. Verwenden Sie dieses Profil beim Ausführen von AWS CLI -Befehlen. Weitere Informationen zu benannten Profilen finden Sie unter Benannte Profile im AWS Command Line Interface Benutzerhandbuch.

   [profile adminuser]
   aws_access_key_id = adminuser access key ID
   aws_secret_access_key = adminuser secret access key
   region = aws-region

   Eine Liste der verfügbaren AWS Regionen finden Sie unter Regionen und Endpunkte in der Allgemeine Amazon Web Services-Referenz.

   Anmerkung

   Der Beispielcode und die Befehle in diesem Tutorial verwenden die Region USA West (Oregon). Um eine andere Region zu verwenden, ändern Sie die Region im Code und in den Befehlen für dieses Tutorial in die Region, die Sie verwenden möchten.

3. Überprüfen Sie die Einrichtung, indem Sie die folgenden Hilfebefehle in die Befehlszeile eingeben:

   aws help

So erstellen Sie die Daten-Streams (AWS CLI)

1. Verwenden Sie den folgenden Amazon Kinesis create-stream AWS CLI Kinesis-Befehl, um den ersten Stream (ExampleInputStream) zu erstellen.

   $ aws kinesis create-stream \
   --stream-name ExampleInputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

2. Um den zweiten Stream zu erstellen, den die Anwendung zum Schreiben der Ausgabe verwendet, führen Sie denselben Befehl aus und ändern den Stream-Namen in ExampleOutputStream.

   $ aws kinesis create-stream \
   --stream-name ExampleOutputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

   
       import datetime
       import json
       import random
       import boto3
       STREAM_NAME = "ExampleInputStream"
       def get_data():
           return {
               'event_time': datetime.datetime.now().isoformat(),
               'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
               'price': round(random.random() * 100, 2)}
       def generate(stream_name, kinesis_client):
           while True:
               data = get_data()
               print(data)
               kinesis_client.put_record(
                   StreamName=stream_name,
                   Data=json.dumps(data),
                   PartitionKey="partitionkey")
       if __name__ == '__main__':
           generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2')) 

2. Im weiteren Verlauf des Tutorials führen Sie das stock.py-Skript zum Senden von Daten an die Anwendung aus.

   $ python stock.py

1. Klonen Sie das Remote-Repository, indem Sie den folgenden Befehl verwenden:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

2. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/GettingStarted Verzeichnis .

Kompilieren des Anwendungscodes

1. Um Ihren Anwendungscode zu verwenden, kompilieren Sie ihn und packen ihn in eine JAR Datei. Sie können Ihren Code auf zwei Arten kompilieren und packen:

   • Verwenden Sie das Befehlszeilen-Maven-Tool. Erstellen Sie Ihre JAR Datei, indem Sie den folgenden Befehl in dem Verzeichnis ausführen, das die pom.xml Datei enthält:

     mvn package -Dflink.version=1.13.2

   • Verwenden Sie Ihre Entwicklungsumgebung. Weitere Informationen finden Sie in der Dokumentation Ihrer Entwicklungsumgebung.

     Anmerkung

     Der bereitgestellte Quellcode basiert auf Bibliotheken aus Java 11.

   Sie können Ihr Paket entweder als JAR Datei hochladen oder Sie können Ihr Paket komprimieren und als ZIP Datei hochladen. Wenn Sie Ihre Anwendung mit dem erstellen AWS CLI, geben Sie Ihren Codeinhaltstyp (JARoderZIP) an.

2. Wenn während der Erstellung Fehler aufgetreten sind, überprüfen Sie, ob Ihre JAVA_HOME-Umgebungsvariable richtig eingestellt ist.

So laden Sie den Anwendungscode hoch

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie Bucket erstellen aus.

3. Geben Sie ka-app-code-<username> im Feld Bucket-Name ein. Fügen Sie dem Bucket-Namen ein Suffix hinzu, wie z. B. Ihren Benutzernamen, damit er global eindeutig ist. Wählen Sie Weiter.

4. Lassen Sie im Schritt Optionen konfigurieren die Einstellungen unverändert und klicken Sie auf Weiter.

5. Lassen Sie im Schritt Berechtigungen festlegen die Einstellungen unverändert und klicken Sie auf Weiter.

6. Wählen Sie Bucket erstellen aus.

7. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

8. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben. Wählen Sie Weiter.

9. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Geben Sie für Beschreibung den Text My java test app ein.

   • Wählen Sie für Runtime (Laufzeit) die Option Apache Flink aus.

   • Behalten Sie im Pulldown-Menü die Version Apache Flink Version 1.13 bei.

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Geben Sie Folgendes ein:

   Gruppen-ID	Schlüssel	Wert
   ProducerConfigProperties	flink.inputstream.initpos	LATEST
   ProducerConfigProperties	aws.region	us-west-2
   ProducerConfigProperties	AggregationEnabled	false

5. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

6. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

7. Wählen Sie Aktualisieren.

So erstellen Sie eine IAM-Rolle

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie im Navigationsbereich Roles (Rollen) und Create Role (Rolle erstellen) aus.

3. Wählen Sie unter Typ der vertrauenswürdigen Entität auswählen die Option AWS -Service aus. Wählen Sie unter Choose the service that will use this role (Wählen Sie den Service aus, der diese Rolle verwendet) die Option Kinesis aus. Wählen Sie unter Select your use case (Wählen Sie Ihren Anwendungsfall aus) die Option Kinesis Analytics aus.

   Wählen Sie Weiter: Berechtigungen aus.

4. Wählen Sie auf der Seite Attach permissions policies (Berechtigungsrichtlinien hinzufügen) Next: Review (Weiter: Überprüfen) aus. Sie fügen Berechtigungsrichtlinien an, nachdem Sie die Rolle erstellt haben.

5. Geben Sie auf der Seite Create role (Rolle erstellen) den Text MF-stream-rw-role für Role name (Rollenname) ein. Wählen Sie Rolle erstellen.

   Jetzt haben Sie eine neue IAM Rolle namens erstelltMF-stream-rw-role. Im nächsten Schritt aktualisieren Sie die Vertrauens- und Berechtigungsrichtlinien für die Rolle.

6. Fügen Sie die Berechtigungsrichtlinie der Rolle an.

   Anmerkung

   Für diese Übung übernimmt Managed Service für Apache Flink diese Rolle sowohl für das Lesen von Daten aus einem Kinesis-Datenstrom (Quelle) als auch zum Schreiben der Ausgabedaten in einen anderen Kinesis-Datenstrom. Daher fügen Sie die Richtlinie an, die Sie im vorherigen Schritt erstellt haben, Erstellen einer Berechtigungsrichtlinie.

   1. Wählen Sie auf der Seite Summary (Übersicht) die Registerkarte Permissions (Berechtigungen) aus.

   2. Wählen Sie Attach Policies (Richtlinien anfügen) aus.

   3. Geben Sie im Suchfeld AKReadSourceStreamWriteSinkStream (die Richtlinie, die Sie im vorhergehenden Abschnitt erstellt haben) ein.

   4. Wählen Sie die AKReadSourceStreamWriteSinkStreamRichtlinie und anschließend Richtlinie anhängen aus.

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namencreate_request.json. Ersetzen Sie die Beispielrolle ARN durch die ARN für die Rolle, die Sie zuvor erstellt haben. Ersetzen Sie das ARN Bucket-Suffix (username) durch das Suffix, das Sie im vorherigen Abschnitt ausgewählt haben. Ersetzen Sie die beispielhafte Konto-ID (012345678901) in der Service-Ausführungsrolle mit Ihrer Konto-ID.

   {
       "ApplicationName": "test",
       "ApplicationDescription": "my java test app",
       "RuntimeEnvironment": "FLINK-1_15",
       "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
       "ApplicationConfiguration": {
           "ApplicationCodeConfiguration": {
               "CodeContent": {
                   "S3ContentLocation": {
                       "BucketARN": "arn:aws:s3:::ka-app-code-username",
                       "FileKey": "aws-kinesis-analytics-java-apps-1.0.jar"
                   }
               },
               "CodeContentType": "ZIPFILE"
           },
           "EnvironmentProperties":  { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
       }
   }
   
   

2. Führen Sie die CreateApplication-Aktion mit der vorherigen Anforderung zum Erstellen der Anwendung aus:

   aws kinesisanalyticsv2 create-application --cli-input-json file://create_request.json

So starten Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namen. start_request.json

   {
       "ApplicationName": "test",
       "RunConfiguration": {
           "ApplicationRestoreConfiguration": { 
            "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
            }
       }
   }
   

2. Führen Sie die StartApplication-Aktion mit der vorherigen Anforderung zum Starten der Anwendung aus:

   aws kinesisanalyticsv2 start-application --cli-input-json file://start_request.json

So stoppen Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstop_request.json.

   {
      "ApplicationName": "test"
   }
   

2. Führen Sie die StopApplication-Aktion mit der folgenden Anforderung zum Stoppen der Anwendung aus:

   aws kinesisanalyticsv2 stop-application --cli-input-json file://stop_request.json

So aktualisieren Sie die Umgebungseigenschaften für die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenupdate_properties_request.json.

   {"ApplicationName": "test",
      "CurrentApplicationVersionId": 1,
      "ApplicationConfigurationUpdate": { 
         "EnvironmentPropertyUpdates": { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
      }
   }
   

2. Führen Sie die UpdateApplication-Aktion mit der vorherigen Anforderung aus, um die Umgebungseigenschaften zu aktualisieren:

   aws kinesisanalyticsv2 update-application --cli-input-json file://update_properties_request.json

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

Um sich für eine anzumelden AWS-Konto

1. Öffnen Sie https://portal.aws.amazon.com/billing/die Anmeldung.

2. Folgen Sie den Online-Anweisungen.

   Bei der Anmeldung müssen Sie auch einen Telefonanruf entgegennehmen und einen Verifizierungscode über die Telefontasten eingeben.

   Wenn Sie sich für eine anmelden AWS-Konto, Root-Benutzer des AWS-Kontoswird eine erstellt. Der Root-Benutzer hat Zugriff auf alle AWS-Services und Ressourcen des Kontos. Als bewährte Sicherheitsmethode weisen Sie einem Administratorbenutzer Administratorzugriff zu und verwenden Sie nur den Root-Benutzer, um Aufgaben auszuführen, die Root-Benutzerzugriff erfordern.

Sichern Sie Ihre Root-Benutzer des AWS-Kontos

1. Melden Sie sich AWS Management Consoleals Kontoinhaber an, indem Sie Root-Benutzer auswählen und Ihre AWS-Konto E-Mail-Adresse eingeben. Geben Sie auf der nächsten Seite Ihr Passwort ein.

   Hilfe bei der Anmeldung mit dem Root-Benutzer finden Sie unter Anmelden als Root-Benutzer im AWS-Anmeldung Benutzerhandbuch zu.

2. Aktivieren Sie die Multi-Faktor-Authentifizierung (MFA) für Ihren Root-Benutzer.

   Anweisungen finden Sie im Benutzerhandbuch unter Aktivieren eines virtuellen MFA Geräts für Ihren AWS-Konto IAM Root-Benutzer (Konsole).

Erstellen eines Benutzers mit Administratorzugriff

1. Aktivieren Sie IAM Identity Center.

   Anweisungen finden Sie unter Aktivieren AWS IAM Identity Center im AWS IAM Identity Center Benutzerhandbuch.

2. Gewähren Sie einem Benutzer in IAM Identity Center Administratorzugriff.

   Ein Tutorial zur Verwendung von IAM-Identity-Center-Verzeichnis als Identitätsquelle finden Sie unter Benutzerzugriff mit der Standardeinstellung konfigurieren IAM-Identity-Center-Verzeichnis im AWS IAM Identity Center Benutzerhandbuch.

Anmelden als Administratorbenutzer

• Um sich mit Ihrem IAM Identity Center-Benutzer anzumelden, verwenden Sie die Anmeldung, URL die an Ihre E-Mail-Adresse gesendet wurde, als Sie den IAM Identity Center-Benutzer erstellt haben.

  Hilfe bei der Anmeldung mit einem IAM Identity Center-Benutzer finden Sie im AWS-Anmeldung Benutzerhandbuch unter Anmeldung beim AWS Zugangsportal.

Weiteren Benutzern Zugriff zuweisen

1. Erstellen Sie in IAM Identity Center einen Berechtigungssatz, der der bewährten Methode zur Anwendung von Berechtigungen mit den geringsten Rechten folgt.

   Anweisungen hierzu finden Sie unter Berechtigungssatz erstellen im AWS IAM Identity Center Benutzerhandbuch.

2. Weisen Sie Benutzer einer Gruppe zu und weisen Sie der Gruppe dann Single Sign-On-Zugriff zu.

   Eine genaue Anleitung finden Sie unter Gruppen hinzufügen im AWS IAM Identity Center Benutzerhandbuch.

Um das einzurichten AWS CLI

1. Herunterladen und Konfigurieren von AWS CLI. Eine Anleitung finden Sie unter den folgenden Themen im AWS Command Line Interface -Benutzerhandbuch:

   • Installieren des AWS Command Line Interface

   • Konfigurieren von AWS CLI

2. Fügen Sie der Datei ein benanntes Profil für den Administratorbenutzer AWS CLI config hinzu. Verwenden Sie dieses Profil beim Ausführen von AWS CLI -Befehlen. Weitere Informationen zu benannten Profilen finden Sie unter Benannte Profile im AWS Command Line Interface Benutzerhandbuch.

   [profile adminuser]
   aws_access_key_id = adminuser access key ID
   aws_secret_access_key = adminuser secret access key
   region = aws-region

   Eine Liste der verfügbaren AWS Regionen finden Sie unter Regionen und Endpunkte in der Allgemeine Amazon Web Services-Referenz.

   Anmerkung

   Der Beispielcode und die Befehle in diesem Tutorial verwenden die Region USA West (Oregon). Um eine andere Region zu verwenden, ändern Sie die Region im Code und in den Befehlen für dieses Tutorial in die Region, die Sie verwenden möchten.

3. Überprüfen Sie die Einrichtung, indem Sie die folgenden Hilfebefehle in die Befehlszeile eingeben:

   aws help

So erstellen Sie die Daten-Streams (AWS CLI)

1. Verwenden Sie den folgenden Amazon Kinesis create-stream AWS CLI Kinesis-Befehl, um den ersten Stream (ExampleInputStream) zu erstellen.

   $ aws kinesis create-stream \
   --stream-name ExampleInputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

2. Um den zweiten Stream zu erstellen, den die Anwendung zum Schreiben der Ausgabe verwendet, führen Sie denselben Befehl aus und ändern den Stream-Namen in ExampleOutputStream.

   $ aws kinesis create-stream \
   --stream-name ExampleOutputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    
   import datetime
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   def get_data():
       return {
           "EVENT_TIME": datetime.datetime.now().isoformat(),
           "TICKER": random.choice(["AAPL", "AMZN", "MSFT", "INTC", "TBV"]),
           "PRICE": round(random.random() * 100, 2),
       }
   
   
   def generate(stream_name, kinesis_client):
       while True:
           data = get_data()
           print(data)
           kinesis_client.put_record(
               StreamName=stream_name, Data=json.dumps(data), PartitionKey="partitionkey"
           )
   
   
   if __name__ == "__main__":
       generate(STREAM_NAME, boto3.client("kinesis"))
   

2. Im weiteren Verlauf des Tutorials führen Sie das stock.py-Skript zum Senden von Daten an die Anwendung aus.

   $ python stock.py

1. Klonen Sie das Remote-Repository, indem Sie den folgenden Befehl verwenden:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

2. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/GettingStarted Verzeichnis .

Kompilieren des Anwendungscodes

1. Um Ihren Anwendungscode zu verwenden, kompilieren Sie ihn und packen ihn in eine JAR Datei. Sie können Ihren Code auf zwei Arten kompilieren und packen:

   • Verwenden Sie das Befehlszeilen-Maven-Tool. Erstellen Sie Ihre JAR Datei, indem Sie den folgenden Befehl in dem Verzeichnis ausführen, das die pom.xml Datei enthält:

     mvn package -Dflink.version=1.11.3

   • Verwenden Sie Ihre Entwicklungsumgebung. Weitere Informationen finden Sie in der Dokumentation Ihrer Entwicklungsumgebung.

     Anmerkung

     Der bereitgestellte Quellcode basiert auf Bibliotheken aus Java 11. Stellen Sie sicher, dass die Java-Version Ihres Projekts 11 ist.

   Sie können Ihr Paket entweder als JAR Datei hochladen oder Sie können Ihr Paket komprimieren und als ZIP Datei hochladen. Wenn Sie Ihre Anwendung mit dem erstellen AWS CLI, geben Sie Ihren Codeinhaltstyp (JARoderZIP) an.

2. Wenn während der Erstellung Fehler aufgetreten sind, überprüfen Sie, ob Ihre JAVA_HOME-Umgebungsvariable richtig eingestellt ist.

So laden Sie den Anwendungscode hoch

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie Bucket erstellen aus.

3. Geben Sie ka-app-code-<username> im Feld Bucket-Name ein. Fügen Sie dem Bucket-Namen ein Suffix hinzu, wie z. B. Ihren Benutzernamen, damit er global eindeutig ist. Wählen Sie Weiter.

4. Lassen Sie im Schritt Optionen konfigurieren die Einstellungen unverändert und klicken Sie auf Weiter.

5. Lassen Sie im Schritt Berechtigungen festlegen die Einstellungen unverändert und klicken Sie auf Weiter.

6. Wählen Sie Bucket erstellen aus.

7. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

8. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben. Wählen Sie Weiter.

9. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Geben Sie für Beschreibung den Text My java test app ein.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

   • Behalten Sie im Pulldown-Menü für die Version Apache Flink Version 1.11 (empfohlene Version) bei.

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Geben Sie unter Eigenschaften für Gruppen-ID den Text ProducerConfigProperties ein.

5. Geben Sie die folgenden Eigenschaften und Werte der Anwendung ein:

   Gruppen-ID	Schlüssel	Wert
   ProducerConfigProperties	flink.inputstream.initpos	LATEST
   ProducerConfigProperties	aws.region	us-west-2
   ProducerConfigProperties	AggregationEnabled	false

6. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

7. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

8. Wählen Sie Aktualisieren.

So erstellen Sie eine IAM-Rolle

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie im Navigationsbereich Roles (Rollen) und Create Role (Rolle erstellen) aus.

3. Wählen Sie unter Typ der vertrauenswürdigen Entität auswählen die Option AWS -Service aus. Wählen Sie unter Choose the service that will use this role (Wählen Sie den Service aus, der diese Rolle verwendet) die Option Kinesis aus. Wählen Sie unter Select your use case (Wählen Sie Ihren Anwendungsfall aus) die Option Kinesis Analytics aus.

   Wählen Sie Weiter: Berechtigungen aus.

4. Wählen Sie auf der Seite Attach permissions policies (Berechtigungsrichtlinien hinzufügen) Next: Review (Weiter: Überprüfen) aus. Sie fügen Berechtigungsrichtlinien an, nachdem Sie die Rolle erstellt haben.

5. Geben Sie auf der Seite Create role (Rolle erstellen) den Text MF-stream-rw-role für Role name (Rollenname) ein. Wählen Sie Rolle erstellen.

   Jetzt haben Sie eine neue IAM Rolle namens erstelltMF-stream-rw-role. Im nächsten Schritt aktualisieren Sie die Vertrauens- und Berechtigungsrichtlinien für die Rolle.

6. Fügen Sie die Berechtigungsrichtlinie der Rolle an.

   Anmerkung

   Für diese Übung übernimmt Managed Service für Apache Flink diese Rolle sowohl für das Lesen von Daten aus einem Kinesis-Datenstrom (Quelle) als auch zum Schreiben der Ausgabedaten in einen anderen Kinesis-Datenstrom. Daher fügen Sie die Richtlinie an, die Sie im vorherigen Schritt erstellt haben, Erstellen einer Berechtigungsrichtlinie.

   1. Wählen Sie auf der Seite Summary (Übersicht) die Registerkarte Permissions (Berechtigungen) aus.

   2. Wählen Sie Attach Policies (Richtlinien anfügen) aus.

   3. Geben Sie im Suchfeld AKReadSourceStreamWriteSinkStream (die Richtlinie, die Sie im vorhergehenden Abschnitt erstellt haben) ein.

   4. Wählen Sie die AKReadSourceStreamWriteSinkStreamRichtlinie und anschließend Richtlinie anhängen aus.

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namencreate_request.json. Ersetzen Sie die Beispielrolle ARN durch die ARN für die Rolle, die Sie zuvor erstellt haben. Ersetzen Sie das ARN Bucket-Suffix (username) durch das Suffix, das Sie im vorherigen Abschnitt ausgewählt haben. Ersetzen Sie die beispielhafte Konto-ID (012345678901) in der Service-Ausführungsrolle mit Ihrer Konto-ID.

   {
       "ApplicationName": "test",
       "ApplicationDescription": "my java test app",
       "RuntimeEnvironment": "FLINK-1_11",
       "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
       "ApplicationConfiguration": {
           "ApplicationCodeConfiguration": {
               "CodeContent": {
                   "S3ContentLocation": {
                       "BucketARN": "arn:aws:s3:::ka-app-code-username",
                       "FileKey": "aws-kinesis-analytics-java-apps-1.0.jar"
                   }
               },
               "CodeContentType": "ZIPFILE"
           },
           "EnvironmentProperties":  { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
       }
   }
   
   

2. Führen Sie die CreateApplication-Aktion mit der vorherigen Anforderung zum Erstellen der Anwendung aus:

   aws kinesisanalyticsv2 create-application --cli-input-json file://create_request.json

So starten Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstart_request.json.

   {
       "ApplicationName": "test",
       "RunConfiguration": {
           "ApplicationRestoreConfiguration": { 
            "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
            }
       }
   }
   

2. Führen Sie die StartApplication-Aktion mit der vorherigen Anforderung zum Starten der Anwendung aus:

   aws kinesisanalyticsv2 start-application --cli-input-json file://start_request.json

So stoppen Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstop_request.json.

   
   {
       "ApplicationName": "test"
   }
   

2. Führen Sie die StopApplication-Aktion mit der folgenden Anforderung zum Stoppen der Anwendung aus:

   aws kinesisanalyticsv2 stop-application --cli-input-json file://stop_request.json

So aktualisieren Sie die Umgebungseigenschaften für die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenupdate_properties_request.json.

   {"ApplicationName": "test",
      "CurrentApplicationVersionId": 1,
      "ApplicationConfigurationUpdate": { 
         "EnvironmentPropertyUpdates": { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
      }
   }
   

2. Führen Sie die UpdateApplication-Aktion mit der vorherigen Anforderung aus, um die Umgebungseigenschaften zu aktualisieren:

   aws kinesisanalyticsv2 update-application --cli-input-json file://update_properties_request.json

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

Um sich für eine anzumelden AWS-Konto

1. Öffnen Sie https://portal.aws.amazon.com/billing/die Anmeldung.

2. Folgen Sie den Online-Anweisungen.

   Bei der Anmeldung müssen Sie auch einen Telefonanruf entgegennehmen und einen Verifizierungscode über die Telefontasten eingeben.

   Wenn Sie sich für eine anmelden AWS-Konto, Root-Benutzer des AWS-Kontoswird eine erstellt. Der Root-Benutzer hat Zugriff auf alle AWS-Services und Ressourcen des Kontos. Als bewährte Sicherheitsmethode weisen Sie einem Administratorbenutzer Administratorzugriff zu und verwenden Sie nur den Root-Benutzer, um Aufgaben auszuführen, die Root-Benutzerzugriff erfordern.

Sichern Sie Ihre Root-Benutzer des AWS-Kontos

1. Melden Sie sich AWS Management Consoleals Kontoinhaber an, indem Sie Root-Benutzer auswählen und Ihre AWS-Konto E-Mail-Adresse eingeben. Geben Sie auf der nächsten Seite Ihr Passwort ein.

   Hilfe bei der Anmeldung mit dem Root-Benutzer finden Sie unter Anmelden als Root-Benutzer im AWS-Anmeldung Benutzerhandbuch zu.

2. Aktivieren Sie die Multi-Faktor-Authentifizierung (MFA) für Ihren Root-Benutzer.

   Anweisungen finden Sie im Benutzerhandbuch unter Aktivieren eines virtuellen MFA Geräts für Ihren AWS-Konto IAM Root-Benutzer (Konsole).

Erstellen eines Benutzers mit Administratorzugriff

1. Aktivieren Sie IAM Identity Center.

   Anweisungen finden Sie unter Aktivieren AWS IAM Identity Center im AWS IAM Identity Center Benutzerhandbuch.

2. Gewähren Sie einem Benutzer in IAM Identity Center Administratorzugriff.

   Ein Tutorial zur Verwendung von IAM-Identity-Center-Verzeichnis als Identitätsquelle finden Sie unter Benutzerzugriff mit der Standardeinstellung konfigurieren IAM-Identity-Center-Verzeichnis im AWS IAM Identity Center Benutzerhandbuch.

Anmelden als Administratorbenutzer

• Um sich mit Ihrem IAM Identity Center-Benutzer anzumelden, verwenden Sie die Anmeldung, URL die an Ihre E-Mail-Adresse gesendet wurde, als Sie den IAM Identity Center-Benutzer erstellt haben.

  Hilfe bei der Anmeldung mit einem IAM Identity Center-Benutzer finden Sie im AWS-Anmeldung Benutzerhandbuch unter Anmeldung beim AWS Zugangsportal.

Weiteren Benutzern Zugriff zuweisen

1. Erstellen Sie in IAM Identity Center einen Berechtigungssatz, der der bewährten Methode zur Anwendung von Berechtigungen mit den geringsten Rechten folgt.

   Anweisungen hierzu finden Sie unter Berechtigungssatz erstellen im AWS IAM Identity Center Benutzerhandbuch.

2. Weisen Sie Benutzer einer Gruppe zu und weisen Sie der Gruppe dann Single Sign-On-Zugriff zu.

   Eine genaue Anleitung finden Sie unter Gruppen hinzufügen im AWS IAM Identity Center Benutzerhandbuch.

Um das einzurichten AWS CLI

1. Herunterladen und Konfigurieren von AWS CLI. Eine Anleitung finden Sie unter den folgenden Themen im AWS Command Line Interface -Benutzerhandbuch:

   • Installieren des AWS Command Line Interface

   • Konfigurieren von AWS CLI

2. Fügen Sie der Datei ein benanntes Profil für den Administratorbenutzer AWS CLI config hinzu. Verwenden Sie dieses Profil beim Ausführen von AWS CLI -Befehlen. Weitere Informationen zu benannten Profilen finden Sie unter Benannte Profile im AWS Command Line Interface Benutzerhandbuch.

   [profile adminuser]
   aws_access_key_id = adminuser access key ID
   aws_secret_access_key = adminuser secret access key
   region = aws-region

   Eine Liste der verfügbaren Regionen finden Sie unter Regionen und Endpunkte in Allgemeine Amazon Web Services-Referenz.

   Anmerkung

   Der Beispielcode und die Befehle in diesem Tutorial verwenden die Region USA West (Oregon). Um eine andere AWS Region zu verwenden, ändern Sie die Region im Code und in den Befehlen für dieses Tutorial in die Region, die Sie verwenden möchten.

3. Überprüfen Sie die Einrichtung, indem Sie die folgenden Hilfebefehle in die Befehlszeile eingeben:

   aws help

So erstellen Sie die Daten-Streams (AWS CLI)

1. Verwenden Sie den folgenden Amazon Kinesis create-stream AWS CLI Kinesis-Befehl, um den ersten Stream (ExampleInputStream) zu erstellen.

   $ aws kinesis create-stream \
   --stream-name ExampleInputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

2. Um den zweiten Stream zu erstellen, den die Anwendung zum Schreiben der Ausgabe verwendet, führen Sie denselben Befehl aus und ändern den Stream-Namen in ExampleOutputStream.

   $ aws kinesis create-stream \
   --stream-name ExampleOutputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    
   import datetime
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   def get_data():
       return {
           "EVENT_TIME": datetime.datetime.now().isoformat(),
           "TICKER": random.choice(["AAPL", "AMZN", "MSFT", "INTC", "TBV"]),
           "PRICE": round(random.random() * 100, 2),
       }
   
   
   def generate(stream_name, kinesis_client):
       while True:
           data = get_data()
           print(data)
           kinesis_client.put_record(
               StreamName=stream_name, Data=json.dumps(data), PartitionKey="partitionkey"
           )
   
   
   if __name__ == "__main__":
       generate(STREAM_NAME, boto3.client("kinesis"))
   

2. Im weiteren Verlauf des Tutorials führen Sie das stock.py-Skript zum Senden von Daten an die Anwendung aus.

   $ python stock.py

1. Klonen Sie das Remote-Repository, indem Sie den folgenden Befehl verwenden:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

2. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/GettingStarted_1_8 Verzeichnis .

Kompilieren des Anwendungscodes

1. Um Ihren Anwendungscode zu verwenden, kompilieren Sie ihn und packen ihn in eine JAR Datei. Sie können Ihren Code auf zwei Arten kompilieren und packen:

   • Verwenden Sie das Befehlszeilen-Maven-Tool. Erstellen Sie Ihre JAR Datei, indem Sie den folgenden Befehl in dem Verzeichnis ausführen, das die pom.xml Datei enthält:

     mvn package -Dflink.version=1.8.2

   • Verwenden Sie Ihre Entwicklungsumgebung. Weitere Informationen finden Sie in der Dokumentation Ihrer Entwicklungsumgebung.

     Anmerkung

     Der bereitgestellte Quellcode basiert auf Bibliotheken aus Java 1.8. Stellen Sie sicher, dass die Java-Version Ihres Projekts 1.8 ist.

   Sie können Ihr Paket entweder als JAR Datei hochladen oder Sie können Ihr Paket komprimieren und als ZIP Datei hochladen. Wenn Sie Ihre Anwendung mit dem erstellen AWS CLI, geben Sie Ihren Codeinhaltstyp (JARoderZIP) an.

2. Wenn während der Erstellung Fehler aufgetreten sind, überprüfen Sie, ob Ihre JAVA_HOME-Umgebungsvariable richtig eingestellt ist.

So laden Sie den Anwendungscode hoch

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie Bucket erstellen aus.

3. Geben Sie ka-app-code-<username> im Feld Bucket-Name ein. Fügen Sie dem Bucket-Namen ein Suffix hinzu, wie z. B. Ihren Benutzernamen, damit er global eindeutig ist. Wählen Sie Weiter.

4. Lassen Sie im Schritt Optionen konfigurieren die Einstellungen unverändert und klicken Sie auf Weiter.

5. Lassen Sie im Schritt Berechtigungen festlegen die Einstellungen unverändert und klicken Sie auf Weiter.

6. Wählen Sie Bucket erstellen aus.

7. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

8. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben. Wählen Sie Weiter.

9. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Geben Sie für Beschreibung den Text My java test app ein.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

   • Behalten Sie im Pulldown-Menü die Option Apache Flink 1.8 (empfohlene Version) bei.

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Geben Sie die folgenden Eigenschaften und Werte der Anwendung ein:

   Gruppen-ID	Schlüssel	Wert
   ProducerConfigProperties	flink.inputstream.initpos	LATEST
   ProducerConfigProperties	aws.region	us-west-2
   ProducerConfigProperties	AggregationEnabled	false

5. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

6. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

7. Wählen Sie Aktualisieren.

1. Wählen Sie auf der MyApplicationSeite die Option Ausführen aus. Bestätigen Sie die Aktion.

2. Wenn die Anwendung ausgeführt wird, aktualisieren Sie die Seite. Die Konsole zeigt den Application graph (Anwendungs-Graph) an.

So erstellen Sie eine IAM-Rolle

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie im Navigationsbereich Roles (Rollen) und Create Role (Rolle erstellen) aus.

3. Wählen Sie unter Typ der vertrauenswürdigen Entität auswählen die Option AWS -Service aus. Wählen Sie unter Choose the service that will use this role (Wählen Sie den Service aus, der diese Rolle verwendet) die Option Kinesis aus. Wählen Sie unter Select your use case (Wählen Sie Ihren Anwendungsfall aus) die Option Kinesis Analytics aus.

   Wählen Sie Weiter: Berechtigungen aus.

4. Wählen Sie auf der Seite Attach permissions policies (Berechtigungsrichtlinien hinzufügen) Next: Review (Weiter: Überprüfen) aus. Sie fügen Berechtigungsrichtlinien an, nachdem Sie die Rolle erstellt haben.

5. Geben Sie auf der Seite Create role (Rolle erstellen) den Text MF-stream-rw-role für Role name (Rollenname) ein. Wählen Sie Rolle erstellen.

   Jetzt haben Sie eine neue IAM Rolle namens erstelltMF-stream-rw-role. Im nächsten Schritt aktualisieren Sie die Vertrauens- und Berechtigungsrichtlinien für die Rolle.

6. Fügen Sie die Berechtigungsrichtlinie der Rolle an.

   Anmerkung

   Für diese Übung übernimmt Managed Service für Apache Flink diese Rolle sowohl für das Lesen von Daten aus einem Kinesis-Datenstrom (Quelle) als auch zum Schreiben der Ausgabedaten in einen anderen Kinesis-Datenstrom. Daher fügen Sie die Richtlinie an, die Sie im vorherigen Schritt erstellt haben, Erstellen einer Berechtigungsrichtlinie.

   1. Wählen Sie auf der Seite Summary (Übersicht) die Registerkarte Permissions (Berechtigungen) aus.

   2. Wählen Sie Attach Policies (Richtlinien anfügen) aus.

   3. Geben Sie im Suchfeld AKReadSourceStreamWriteSinkStream (die Richtlinie, die Sie im vorhergehenden Abschnitt erstellt haben) ein.

   4. Wählen Sie die AKReadSourceStreamWriteSinkStreamRichtlinie und anschließend Richtlinie anhängen aus.

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namencreate_request.json. Ersetzen Sie die Beispielrolle ARN durch die ARN für die Rolle, die Sie zuvor erstellt haben. Ersetzen Sie das ARN Bucket-Suffix (username) durch das Suffix, das Sie im vorherigen Abschnitt ausgewählt haben. Ersetzen Sie die beispielhafte Konto-ID (012345678901) in der Service-Ausführungsrolle mit Ihrer Konto-ID.

   {
       "ApplicationName": "test",
       "ApplicationDescription": "my java test app",
       "RuntimeEnvironment": "FLINK-1_8",
       "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
       "ApplicationConfiguration": {
           "ApplicationCodeConfiguration": {
               "CodeContent": {
                   "S3ContentLocation": {
                       "BucketARN": "arn:aws:s3:::ka-app-code-username",
                       "FileKey": "aws-kinesis-analytics-java-apps-1.0.jar"
                   }
               },
               "CodeContentType": "ZIPFILE"
           },
           "EnvironmentProperties":  { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
       }
   }
   
   

2. Führen Sie die CreateApplication-Aktion mit der vorherigen Anforderung zum Erstellen der Anwendung aus:

   aws kinesisanalyticsv2 create-application --cli-input-json file://create_request.json

So starten Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstart_request.json.

   {
       "ApplicationName": "test",
       "RunConfiguration": {
           "ApplicationRestoreConfiguration": { 
            "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
            }
       }
   }
   

2. Führen Sie die StartApplication-Aktion mit der vorherigen Anforderung zum Starten der Anwendung aus:

   aws kinesisanalyticsv2 start-application --cli-input-json file://start_request.json

So stoppen Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstop_request.json.

   
   {
      "ApplicationName": "test"
   }
   

2. Führen Sie die StopApplication-Aktion mit der folgenden Anforderung zum Stoppen der Anwendung aus:

   aws kinesisanalyticsv2 stop-application --cli-input-json file://stop_request.json

So aktualisieren Sie die Umgebungseigenschaften für die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenupdate_properties_request.json.

   {"ApplicationName": "test",
      "CurrentApplicationVersionId": 1,
      "ApplicationConfigurationUpdate": { 
         "EnvironmentPropertyUpdates": { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
      }
   }
   

2. Führen Sie die UpdateApplication-Aktion mit der vorherigen Anforderung aus, um die Umgebungseigenschaften zu aktualisieren:

   aws kinesisanalyticsv2 update-application --cli-input-json file://update_properties_request.json

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie Konfigurieren aus.

4. Wählen Sie im Abschnitt Snapshots die Option Deaktivieren und anschließend Aktualisieren aus.

5. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie den Löschvorgang.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

Um sich für eine anzumelden AWS-Konto

1. Öffnen Sie https://portal.aws.amazon.com/billing/die Anmeldung.

2. Folgen Sie den Online-Anweisungen.

   Bei der Anmeldung müssen Sie auch einen Telefonanruf entgegennehmen und einen Verifizierungscode über die Telefontasten eingeben.

   Wenn Sie sich für eine anmelden AWS-Konto, Root-Benutzer des AWS-Kontoswird eine erstellt. Der Root-Benutzer hat Zugriff auf alle AWS-Services und Ressourcen des Kontos. Als bewährte Sicherheitsmethode weisen Sie einem Administratorbenutzer Administratorzugriff zu und verwenden Sie nur den Root-Benutzer, um Aufgaben auszuführen, die Root-Benutzerzugriff erfordern.

Sichern Sie Ihre Root-Benutzer des AWS-Kontos

1. Melden Sie sich AWS Management Consoleals Kontoinhaber an, indem Sie Root-Benutzer auswählen und Ihre AWS-Konto E-Mail-Adresse eingeben. Geben Sie auf der nächsten Seite Ihr Passwort ein.

   Hilfe bei der Anmeldung mit dem Root-Benutzer finden Sie unter Anmelden als Root-Benutzer im AWS-Anmeldung Benutzerhandbuch zu.

2. Aktivieren Sie die Multi-Faktor-Authentifizierung (MFA) für Ihren Root-Benutzer.

   Anweisungen finden Sie im Benutzerhandbuch unter Aktivieren eines virtuellen MFA Geräts für Ihren AWS-Konto IAM Root-Benutzer (Konsole).

Erstellen eines Benutzers mit Administratorzugriff

1. Aktivieren Sie IAM Identity Center.

   Anweisungen finden Sie unter Aktivieren AWS IAM Identity Center im AWS IAM Identity Center Benutzerhandbuch.

2. Gewähren Sie einem Benutzer in IAM Identity Center Administratorzugriff.

   Ein Tutorial zur Verwendung von IAM-Identity-Center-Verzeichnis als Identitätsquelle finden Sie unter Benutzerzugriff mit der Standardeinstellung konfigurieren IAM-Identity-Center-Verzeichnis im AWS IAM Identity Center Benutzerhandbuch.

Anmelden als Administratorbenutzer

• Um sich mit Ihrem IAM Identity Center-Benutzer anzumelden, verwenden Sie die Anmeldung, URL die an Ihre E-Mail-Adresse gesendet wurde, als Sie den IAM Identity Center-Benutzer erstellt haben.

  Hilfe bei der Anmeldung mit einem IAM Identity Center-Benutzer finden Sie im AWS-Anmeldung Benutzerhandbuch unter Anmeldung beim AWS Zugangsportal.

Weiteren Benutzern Zugriff zuweisen

1. Erstellen Sie in IAM Identity Center einen Berechtigungssatz, der der bewährten Methode zur Anwendung von Berechtigungen mit den geringsten Rechten folgt.

   Anweisungen hierzu finden Sie unter Berechtigungssatz erstellen im AWS IAM Identity Center Benutzerhandbuch.

2. Weisen Sie Benutzer einer Gruppe zu und weisen Sie der Gruppe dann Single Sign-On-Zugriff zu.

   Eine genaue Anleitung finden Sie unter Gruppen hinzufügen im AWS IAM Identity Center Benutzerhandbuch.

Um das einzurichten AWS CLI

1. Herunterladen und Konfigurieren von AWS CLI. Eine Anleitung finden Sie unter den folgenden Themen im AWS Command Line Interface -Benutzerhandbuch:

   • Installieren des AWS Command Line Interface

   • Konfigurieren von AWS CLI

2. Fügen Sie der Datei ein benanntes Profil für den Administratorbenutzer AWS CLI config hinzu. Verwenden Sie dieses Profil beim Ausführen von AWS CLI -Befehlen. Weitere Informationen zu benannten Profilen finden Sie unter Benannte Profile im AWS Command Line Interface Benutzerhandbuch.

   [profile adminuser]
   aws_access_key_id = adminuser access key ID
   aws_secret_access_key = adminuser secret access key
   region = aws-region

   Eine Liste der verfügbaren AWS Regionen finden Sie unter Regionen und Endpunkte in der Allgemeine Amazon Web Services-Referenz.

   Anmerkung

   Der Beispielcode und die Befehle in diesem Tutorial verwenden die Region USA West (Oregon). Um eine andere Region zu verwenden, ändern Sie die Region im Code und in den Befehlen für dieses Tutorial in die Region, die Sie verwenden möchten.

3. Überprüfen Sie die Einrichtung, indem Sie die folgenden Hilfebefehle in die Befehlszeile eingeben:

   aws help

So erstellen Sie die Daten-Streams (AWS CLI)

1. Verwenden Sie den folgenden Amazon Kinesis create-stream AWS CLI Kinesis-Befehl, um den ersten Stream (ExampleInputStream) zu erstellen.

   $ aws kinesis create-stream \
   --stream-name ExampleInputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

2. Um den zweiten Stream zu erstellen, den die Anwendung zum Schreiben der Ausgabe verwendet, führen Sie denselben Befehl aus und ändern den Stream-Namen in ExampleOutputStream.

   $ aws kinesis create-stream \
   --stream-name ExampleOutputStream \
   --shard-count 1 \
   --region us-west-2 \
   --profile adminuser

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    
   import datetime
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   def get_data():
       return {
           "EVENT_TIME": datetime.datetime.now().isoformat(),
           "TICKER": random.choice(["AAPL", "AMZN", "MSFT", "INTC", "TBV"]),
           "PRICE": round(random.random() * 100, 2),
       }
   
   
   def generate(stream_name, kinesis_client):
       while True:
           data = get_data()
           print(data)
           kinesis_client.put_record(
               StreamName=stream_name, Data=json.dumps(data), PartitionKey="partitionkey"
           )
   
   
   if __name__ == "__main__":
       generate(STREAM_NAME, boto3.client("kinesis"))
   

2. Im weiteren Verlauf des Tutorials führen Sie das stock.py-Skript zum Senden von Daten an die Anwendung aus.

   $ python stock.py

1. Klonen Sie das Remote-Repository, indem Sie den folgenden Befehl verwenden:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

2. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/GettingStarted_1_6 Verzeichnis .

Kompilieren des Anwendungscodes

1. Um Ihren Anwendungscode zu verwenden, kompilieren Sie ihn und packen ihn in eine JAR Datei. Sie können Ihren Code auf zwei Arten kompilieren und packen:

   • Verwenden Sie das Befehlszeilen-Maven-Tool. Erstellen Sie Ihre JAR Datei, indem Sie den folgenden Befehl in dem Verzeichnis ausführen, das die pom.xml Datei enthält:

     mvn package

     Anmerkung

     Der Parameter -Dflink.version ist für Managed Service für Apache Flink Laufzeit Version 1.0.1 nicht erforderlich; er ist nur für Version 1.1.0 und höher erforderlich. Weitere Informationen finden Sie unter Geben Sie die Apache Flink-Version Ihrer Anwendung an.

   • Verwenden Sie Ihre Entwicklungsumgebung. Weitere Informationen finden Sie in der Dokumentation Ihrer Entwicklungsumgebung.

   Sie können Ihr Paket entweder als JAR Datei hochladen oder Sie können Ihr Paket komprimieren und als ZIP Datei hochladen. Wenn Sie Ihre Anwendung mit dem erstellen AWS CLI, geben Sie Ihren Codeinhaltstyp (JARoderZIP) an.

2. Wenn während der Erstellung Fehler aufgetreten sind, überprüfen Sie, ob Ihre JAVA_HOME-Umgebungsvariable richtig eingestellt ist.

So laden Sie den Anwendungscode hoch

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie Bucket erstellen aus.

3. Geben Sie ka-app-code-<username> im Feld Bucket-Name ein. Fügen Sie dem Bucket-Namen ein Suffix hinzu, wie z. B. Ihren Benutzernamen, damit er global eindeutig ist. Wählen Sie Weiter.

4. Lassen Sie im Schritt Optionen konfigurieren die Einstellungen unverändert und klicken Sie auf Weiter.

5. Lassen Sie im Schritt Berechtigungen festlegen die Einstellungen unverändert und klicken Sie auf Weiter.

6. Wählen Sie Bucket erstellen aus.

7. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

8. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben. Wählen Sie Weiter.

9. Lassen Sie im Schritt Berechtigungen festlegen die Einstellungen unverändert. Wählen Sie Weiter.

10. Lassen Sie im Schritt Eigenschaften festlegen die Einstellungen unverändert. Klicken Sie auf Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Geben Sie für Beschreibung den Text My java test app ein.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

     Anmerkung

     Managed Service für Apache Flink verwendet Apache Flink Version 1.8.2 oder 1.6.2.

   • Ändern Sie den Versions-Pulldown auf Apache Flink 1.6.

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/java-getting-started-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert java-getting-started-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Geben Sie die folgenden Eigenschaften und Werte der Anwendung ein:

   Gruppen-ID	Schlüssel	Wert
   ProducerConfigProperties	flink.inputstream.initpos	LATEST
   ProducerConfigProperties	aws.region	us-west-2
   ProducerConfigProperties	AggregationEnabled	false

5. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

6. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

7. Wählen Sie Aktualisieren.

1. Wählen Sie auf der MyApplicationSeite die Option Ausführen aus. Bestätigen Sie die Aktion.

2. Wenn die Anwendung ausgeführt wird, aktualisieren Sie die Seite. Die Konsole zeigt den Application graph (Anwendungs-Graph) an.

So erstellen Sie eine IAM-Rolle

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie im Navigationsbereich Roles (Rollen) und Create Role (Rolle erstellen) aus.

3. Wählen Sie unter Typ der vertrauenswürdigen Entität auswählen die Option AWS -Service aus. Wählen Sie unter Choose the service that will use this role (Wählen Sie den Service aus, der diese Rolle verwendet) die Option Kinesis aus. Wählen Sie unter Select your use case (Wählen Sie Ihren Anwendungsfall aus) die Option Kinesis Analytics aus.

   Wählen Sie Weiter: Berechtigungen aus.

4. Wählen Sie auf der Seite Attach permissions policies (Berechtigungsrichtlinien hinzufügen) Next: Review (Weiter: Überprüfen) aus. Sie fügen Berechtigungsrichtlinien an, nachdem Sie die Rolle erstellt haben.

5. Geben Sie auf der Seite Create role (Rolle erstellen) den Text MF-stream-rw-role für Role name (Rollenname) ein. Wählen Sie Rolle erstellen.

   Jetzt haben Sie eine neue IAM Rolle namens erstelltMF-stream-rw-role. Im nächsten Schritt aktualisieren Sie die Vertrauens- und Berechtigungsrichtlinien für die Rolle.

6. Fügen Sie die Berechtigungsrichtlinie der Rolle an.

   Anmerkung

   Für diese Übung übernimmt Managed Service für Apache Flink diese Rolle sowohl für das Lesen von Daten aus einem Kinesis-Datenstrom (Quelle) als auch zum Schreiben der Ausgabedaten in einen anderen Kinesis-Datenstrom. Daher fügen Sie die Richtlinie an, die Sie im vorherigen Schritt erstellt haben, Erstellen einer Berechtigungsrichtlinie.

   1. Wählen Sie auf der Seite Summary (Übersicht) die Registerkarte Permissions (Berechtigungen) aus.

   2. Wählen Sie Attach Policies (Richtlinien anfügen) aus.

   3. Geben Sie im Suchfeld AKReadSourceStreamWriteSinkStream (die Richtlinie, die Sie im vorhergehenden Abschnitt erstellt haben) ein.

   4. Wählen Sie die AKReadSourceStreamWriteSinkStreamRichtlinie und anschließend Richtlinie anhängen aus.

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namencreate_request.json. Ersetzen Sie die Beispielrolle ARN durch die ARN für die Rolle, die Sie zuvor erstellt haben. Ersetzen Sie das ARN Bucket-Suffix (username) durch das Suffix, das Sie im vorherigen Abschnitt ausgewählt haben. Ersetzen Sie die beispielhafte Konto-ID (012345678901) in der Service-Ausführungsrolle mit Ihrer Konto-ID.

   {
       "ApplicationName": "test",
       "ApplicationDescription": "my java test app",
       "RuntimeEnvironment": "FLINK-1_6",
       "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
       "ApplicationConfiguration": {
           "ApplicationCodeConfiguration": {
               "CodeContent": {
                   "S3ContentLocation": {
                       "BucketARN": "arn:aws:s3:::ka-app-code-username",
                       "FileKey": "java-getting-started-1.0.jar"
                   }
               },
               "CodeContentType": "ZIPFILE"
           },
           "EnvironmentProperties":  { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
       }
   }
   
   

2. Führen Sie die CreateApplication-Aktion mit der vorherigen Anforderung zum Erstellen der Anwendung aus:

   aws kinesisanalyticsv2 create-application --cli-input-json file://create_request.json

So starten Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstart_request.json.

   {
       "ApplicationName": "test",
       "RunConfiguration": {
           "ApplicationRestoreConfiguration": { 
            "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
            }
       }
   }
   

2. Führen Sie die StartApplication-Aktion mit der vorherigen Anforderung zum Starten der Anwendung aus:

   aws kinesisanalyticsv2 start-application --cli-input-json file://start_request.json

So stoppen Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstop_request.json.

   {
      "ApplicationName": "test"
   }
   

2. Führen Sie die StopApplication-Aktion mit der folgenden Anforderung zum Stoppen der Anwendung aus:

   aws kinesisanalyticsv2 stop-application --cli-input-json file://stop_request.json

So aktualisieren Sie die Umgebungseigenschaften für die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenupdate_properties_request.json.

   {"ApplicationName": "test",
      "CurrentApplicationVersionId": 1,
      "ApplicationConfigurationUpdate": { 
         "EnvironmentPropertyUpdates": { 
            "PropertyGroups": [ 
               { 
                  "PropertyGroupId": "ProducerConfigProperties",
                  "PropertyMap" : {
                       "flink.stream.initpos" : "LATEST",
                       "aws.region" : "us-west-2",
                       "AggregationEnabled" : "false"
                  }
               },
               { 
                  "PropertyGroupId": "ConsumerConfigProperties",
                  "PropertyMap" : {
                       "aws.region" : "us-west-2"
                  }
               }
            ]
         }
      }
   }
   

2. Führen Sie die UpdateApplication-Aktion mit der vorherigen Anforderung aus, um die Umgebungseigenschaften zu aktualisieren:

   aws kinesisanalyticsv2 update-application --cli-input-json file://update_properties_request.json

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie Konfigurieren aus.

4. Wählen Sie im Abschnitt Snapshots die Option Deaktivieren und anschließend Aktualisieren aus.

5. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie den Löschvorgang.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

   
       import datetime
       import json
       import random
       import boto3
   
       STREAM_NAME = "ExampleInputStream"
   
   
       def get_data():
           return {
               'event_time': datetime.datetime.now().isoformat(),
               'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
               'price': round(random.random() * 100, 2)}
   
   
       def generate(stream_name, kinesis_client):
           while True:
               data = get_data()
               print(data)
               kinesis_client.put_record(
                   StreamName=stream_name,
                   Data=json.dumps(data),
                   PartitionKey="partitionkey")
   
   
       if __name__ == '__main__':
           generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2'))

2. Führen Sie das stock.pySkript aus:

   $ python stock.py

   Lassen Sie das Skript laufen, während Sie den Rest des Tutorials abschließen.

1. Installieren Sie den Git-Client, wenn Sie dies noch nicht getan haben. Weitere Informationen finden Sie unter Git installieren.

2. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/TumblingWindow Verzeichnis .

1. Installieren Sie Java und Maven, wenn das noch nicht geschehen ist. Weitere Informationen finden Sie unter Erfüllen Sie die erforderlichen Voraussetzungen im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

2. Kompilieren Sie die Anwendung mit dem folgenden Befehl:

   mvn package -Dflink.version=1.15.3

   Anmerkung

   Der bereitgestellte Quellcode basiert auf Bibliotheken von Java 11.

1. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

2. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

3. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

     Anmerkung

     Managed Service für Apache Flink verwendet Apache Flink Version 1.15.2.

   • Belassen Sie den Versions-Pulldown bei Apache Flink Version 1.15.2 (empfohlene Version).

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "logs:DescribeLogGroups",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*",
                   "arn:aws:s3:::ka-app-code-<username>/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": "logs:DescribeLogStreams",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": "logs:PutLogEvents",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
           },
           {
               "Sid": "ListCloudwatchLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

5. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

6. Wählen Sie Aktualisieren.

1. Wählen Sie auf der MyApplicationSeite die Option Ausführen aus. Lassen Sie die Option Ohne Snapshot ausführen aktiviert und bestätigen Sie die Aktion.

2. Wenn die Anwendung ausgeführt wird, aktualisieren Sie die Seite. Die Konsole zeigt den Application graph (Anwendungs-Graph) an.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    
   import datetime
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   def get_data():
       return {
           "EVENT_TIME": datetime.datetime.now().isoformat(),
           "TICKER": random.choice(["AAPL", "AMZN", "MSFT", "INTC", "TBV"]),
           "PRICE": round(random.random() * 100, 2),
       }
   
   
   def generate(stream_name, kinesis_client):
       while True:
           data = get_data()
           print(data)
           kinesis_client.put_record(
               StreamName=stream_name, Data=json.dumps(data), PartitionKey="partitionkey"
           )
   
   
   if __name__ == "__main__":
       generate(STREAM_NAME, boto3.client("kinesis"))
   

2. Führen Sie das stock.pySkript aus:

   $ python stock.py

   Lassen Sie das Skript laufen, während Sie den Rest des Tutorials abschließen.

1. Installieren Sie den Git-Client, wenn Sie dies noch nicht getan haben. Weitere Informationen finden Sie unter Git installieren.

2. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/SlidingWindow Verzeichnis .

1. Installieren Sie Java und Maven, wenn das noch nicht geschehen ist. Weitere Informationen finden Sie unter Erfüllen Sie die erforderlichen Voraussetzungen im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

2. Kompilieren Sie die Anwendung mit dem folgenden Befehl:

   mvn package -Dflink.version=1.15.3

   Anmerkung

   Der bereitgestellte Quellcode basiert auf Bibliotheken von Java 11.

1. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie dann Upload.

2. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

3. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

   • Belassen Sie den Versions-Pulldown bei Apache Flink Version 1.15.2 (empfohlene Version).

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "logs:DescribeLogGroups",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*",
                   "arn:aws:s3:::ka-app-code-<username>/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": "logs:DescribeLogStreams",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": "logs:PutLogEvents",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
           },
           {
               "Sid": "ListCloudwatchLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

5. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

6. Wählen Sie Aktualisieren.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Managed Service für Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

   
       import datetime
       import json
       import random
       import boto3
   
       STREAM_NAME = "ExampleInputStream"
   
   
       def get_data():
           return {
               'event_time': datetime.datetime.now().isoformat(),
               'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
               'price': round(random.random() * 100, 2)}
   
   
       def generate(stream_name, kinesis_client):
           while True:
               data = get_data()
               print(data)
               kinesis_client.put_record(
                   StreamName=stream_name,
                   Data=json.dumps(data),
                   PartitionKey="partitionkey")
   
   
       if __name__ == '__main__':
           generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2'))

2. Führen Sie das stock.pySkript aus:

   $ python stock.py

   Lassen Sie das Skript laufen, während Sie den Rest des Tutorials abschließen.

1. Installieren Sie den Git-Client, wenn Sie dies noch nicht getan haben. Weitere Informationen finden Sie unter Git installieren.

2. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/S3Sink Verzeichnis .

1. Installieren Sie Java und Maven, wenn das noch nicht geschehen ist. Weitere Informationen finden Sie unter Erfüllen Sie die erforderlichen Voraussetzungen im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

2. Kompilieren Sie die Anwendung mit dem folgenden Befehl:

   mvn package -Dflink.version=1.15.3

1. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket, navigieren Sie zum Code-Ordner und wählen Sie Upload.

2. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

3. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

   • Belassen Sie den Versions-Pulldown bei Apache Flink Version 1.15.2 (empfohlene Version).

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

   Anmerkung

   Wenn Sie mithilfe der Konsole eine Managed Service for Apache Flink-Anwendung erstellen, haben Sie die Möglichkeit, eine IAM Rolle und Richtlinie für Ihre Anwendung erstellen zu lassen. Ihre Anwendung verwendet diese Rolle und Richtlinie für den Zugriff auf ihre abhängigen Ressourcen. Diese IAM Ressourcen werden anhand Ihres Anwendungsnamens und Ihrer Region wie folgt benannt:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

   • Belassen Sie die Version als Apache Flink Version 1.15.2 (empfohlene Version).

6. Wählen Sie für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

7. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID. Ersetzen Sie <username> durch Ihren Benutzernamen.

   {
               "Sid": "S3",
               "Effect": "Allow",
               "Action": [
                   "s3:Abort*",
                   "s3:DeleteObject*",
                   "s3:GetObject*",
                   "s3:GetBucket*",
                   "s3:List*",
                   "s3:ListBucket",
                   "s3:PutObject"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-<username>",
                   "arn:aws:s3:::ka-app-code-<username>/*"
               ]
             }, 
           {
               "Sid": "ListCloudwatchLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:region:account-id:log-group:*"
               ]
           },
           {
               "Sid": "ListCloudwatchLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:region:account-id:log-group:%LOG_GROUP_PLACEHOLDER%:log-stream:*"
               ]
           },
           {
               "Sid": "PutCloudwatchLogs",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:region:account-id:log-group:%LOG_GROUP_PLACEHOLDER%:log-stream:%LOG_STREAM_PLACEHOLDER%"
               ]
           }
           ,
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert code/aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

5. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

6. Wählen Sie Aktualisieren.

1. Wählen Sie auf der MyApplicationSeite die Option Ausführen aus. Lassen Sie die Option Ohne Snapshot ausführen aktiviert und bestätigen Sie die Aktion.

2. Wenn die Anwendung ausgeführt wird, aktualisieren Sie die Seite. Die Konsole zeigt den Application graph (Anwendungs-Graph) an.

1. Fügen Sie am Anfang der S3StreamingSinkJob.java-Datei die folgenden Importanweisungen hinzu:

   import org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy;
   import org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.DateTimeBucketAssigner;

2. Aktualisieren Sie die createS3SinkFromStaticConfig()-Methode im Code so, dass sie wie folgt aussieht:

   private static StreamingFileSink<String> createS3SinkFromStaticConfig() {
   
       final StreamingFileSink<String> sink = StreamingFileSink
           .forRowFormat(new Path(s3SinkPath), new SimpleStringEncoder<String>("UTF-8"))
           .withBucketAssigner(new DateTimeBucketAssigner("yyyy-MM-dd--HH"))
           .withRollingPolicy(DefaultRollingPolicy.create().build())
           .build();
       return sink;
   }
               

1. Erhöhen Sie die CheckpointInterval-Einstellung der Anwendung. Die folgende Eingabe für die UpdateApplicationAktion legt das Checkpoint-Intervall auf 10 Minuten fest:

   {
      "ApplicationConfigurationUpdate": {  
         "FlinkApplicationConfigurationUpdate": { 
            "CheckpointConfigurationUpdate": {
               "ConfigurationTypeUpdate" : "CUSTOM", 
               "CheckpointIntervalUpdate": 600000
            }
         }
      },
      "ApplicationName": "MyApplication",
      "CurrentApplicationVersionId": 5
   }

   Geben Sie die aktuelle Anwendungsversion an, um den vorherigen Code zu verwenden. Sie können die Anwendungsversion mithilfe der ListApplicationsAktion abrufen.

2. Fügen Sie am Anfang der S3StreamingSinkJob.java-Datei die folgende Importanweisung hinzu:

   import java.util.concurrent.TimeUnit; 

3. Aktualisieren Sie die createS3SinkFromStaticConfig-Methode in der S3StreamingSinkJob.java-Datei so, dass sie wie folgt aussieht:

   private static StreamingFileSink<String> createS3SinkFromStaticConfig() {
   
           final StreamingFileSink<String> sink = StreamingFileSink
                   .forRowFormat(new Path(s3SinkPath), new SimpleStringEncoder<String>("UTF-8"))
                   .withBucketAssigner(new DateTimeBucketAssigner("yyyy-MM-dd--HH"))
                   .withRollingPolicy(
                           DefaultRollingPolicy.create()
                               .withRolloverInterval(TimeUnit.MINUTES.toMillis(8))
                               .withInactivityInterval(TimeUnit.MINUTES.toMillis(5))
                               .withMaxPartSize(1024 * 1024 * 1024)
                               .build())
                   .build();
           return sink;
       }

   Im vorherigen Codebeispiel wird die Häufigkeit von Schreibvorgängen in den Amazon S3-Bucket auf 8 Minuten festgelegt.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Managed Service für Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Richtlinien aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Rollen aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie auf der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

1. Installieren Sie den Git-Client, wenn Sie dies noch nicht getan haben. Weitere Informationen finden Sie unter Git installieren.

2. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Der Anwendungscode befindet sich in der amazon-kinesis-data-analytics-java-examples/KafkaConnectors/KafkaGettingStartedJob.java-Datei. Sie können den Code untersuchen, um sich mit der Struktur des Anwendungscodes von Managed Service für Apache Flink vertraut zu machen.

4. Verwenden Sie entweder das Befehlszeilentool Maven oder Ihre bevorzugte Entwicklungsumgebung, um die Datei zu erstellen. JAR Um die JAR Datei mit dem Maven-Befehlszeilentool zu kompilieren, geben Sie Folgendes ein:

   mvn package -Dflink.version=1.15.3

   Wenn der Build erfolgreich ist, wird die folgende Datei erstellt:

   target/KafkaGettingStartedJob-1.0.jar

   Anmerkung

   Der bereitgestellte Quellcode basiert auf Bibliotheken von Java 11. Wenn Sie eine Entwicklungsumgebung verwenden,

1. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

2. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der KafkaGettingStartedJob-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

3. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink.

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink 1.15.2 aus.

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert KafkaGettingStartedJob-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

   Anmerkung

   Wenn Sie Anwendungsressourcen mithilfe der Konsole angeben (z. B. CloudWatch Logs oder AmazonVPC), ändert die Konsole Ihre Anwendungsausführungsrolle, um Berechtigungen für den Zugriff auf diese Ressourcen zu gewähren.

4. Wählen Sie unter Eigenschaften die Option Gruppe hinzufügen aus. Geben Sie die folgenden Eigenschaften ein:

   Gruppen-ID	Schlüssel	Wert
   KafkaSource	Thema	AWS KafkaTutorialTopic
   KafkaSource	bootstrap.servers	The bootstrap server list you saved previously
   KafkaSource	security.protocol	SSL
   KafkaSource	ssl.truststore.location	/usr/lib/jvm/java-11-amazon-corretto/lib/security/cacerts
   KafkaSource	ssl.truststore.passwort	changeit

   Anmerkung

   Das ssl.truststore.password für das Standardzertifikat ist „changeit“. Sie müssen diesen Wert nicht ändern, wenn Sie das Standardzertifikat verwenden.

   Wählen Sie erneut Gruppe hinzufügen. Geben Sie die folgenden Eigenschaften ein:

   Gruppen-ID	Schlüssel	Wert
   KafkaSink	Thema	AWS KafkaTutorialTopicDestination
   KafkaSink	bootstrap.servers	The bootstrap server list you saved previously
   KafkaSink	security.protocol	SSL
   KafkaSink	ssl.truststore.location	/usr/lib/jvm/java-11-amazon-corretto/lib/security/cacerts
   KafkaSink	ssl.truststore.passwort	changeit
   KafkaSink	transaction.timeout.ms	1000

   Der Anwendungscode liest die oben genannten Anwendungseigenschaften, um die Quelle und Senke zu konfigurieren, die für die Interaktion mit Ihrem VPC und dem MSK Amazon-Cluster verwendet werden. Weitere Informationen zur Verwendung von Eigenschaften finden Sie unter Verwenden Sie Laufzeiteigenschaften in Managed Service für Apache Flink.

5. Wählen Sie unter Snapshots die Option Deaktivieren aus. Dadurch wird es einfacher, die Anwendung zu aktualisieren, ohne ungültige Anwendungsstatusdaten zu laden.

6. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

7. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

8. Wählen Sie im Abschnitt Virtual Private Cloud (VPC) die aus, VPC die Sie Ihrer Anwendung zuordnen möchten. Wählen Sie die zugehörigen Subnetze und Sicherheitsgruppen ausVPC, die die Anwendung für den Zugriff auf VPC Ressourcen verwenden soll.

9. Wählen Sie Aktualisieren.

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    
       import datetime
       import json
       import random
       import boto3
   
       STREAM_NAME = "ExampleInputStream"
   
   
       def get_data():
           return {
               'event_time': datetime.datetime.now().isoformat(),
               'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
               'price': round(random.random() * 100, 2)}
   
   
       def generate(stream_name, kinesis_client):
           while True:
               data = get_data()
               print(data)
               kinesis_client.put_record(
                   StreamName=stream_name,
                   Data=json.dumps(data),
                   PartitionKey="partitionkey")
   
   
       if __name__ == '__main__':
           generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2'))

2. Führen Sie das stock.pySkript aus:

   $ python stock.py

   Lassen Sie das Skript laufen, während Sie den Rest des Tutorials abschließen.

1. Installieren Sie den Git-Client, wenn Sie dies noch nicht getan haben. Weitere Informationen finden Sie unter Git installieren.

2. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/EfoConsumer Verzeichnis .

1. Installieren Sie Java und Maven, wenn das noch nicht geschehen ist. Weitere Informationen finden Sie unter Erfüllen Sie die erforderlichen Voraussetzungen im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

2. Kompilieren Sie die Anwendung mit dem folgenden Befehl:

   mvn package -Dflink.version=1.15.3

   Anmerkung

   Der bereitgestellte Quellcode basiert auf Bibliotheken von Java 11.

1. Wählen Sie in der Amazon S3 S3-Konsole die Option ka-app-code -<username>Bucket und wählen Sie Upload.

2. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der aws-kinesis-analytics-java-apps-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

3. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

     Anmerkung

     Managed Service für Apache Flink verwendet Apache Flink Version 1.15.2.

   • Belassen Sie den Versions-Pulldown bei Apache Flink Version 1.15.2 (empfohlene Version).

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie das Beispielkonto IDs (012345678901) durch Ihre Konto-ID.

   Anmerkung

   Diese Berechtigungen gewähren der Anwendung die Möglichkeit, auf den EFO Verbraucher zuzugreifen.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "logs:DescribeLogGroups",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*",
                   "arn:aws:s3:::ka-app-code-<username>/aws-kinesis-analytics-java-apps-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": "logs:DescribeLogStreams",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": "logs:PutLogEvents",
               "Resource": "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
           },
           {
               "Sid": "ListCloudwatchLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "AllStreams",
               "Effect": "Allow",
               "Action": [
                   "kinesis:ListShards",
                   "kinesis:ListStreamConsumers",
                   "kinesis:DescribeStreamSummary"
               ],
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/*"
           },
           {
               "Sid": "Stream",
               "Effect": "Allow",
               "Action": [
                   "kinesis:DescribeStream",
                   "kinesis:RegisterStreamConsumer",
                   "kinesis:DeregisterStreamConsumer"
               ],
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           },
           {
               "Sid": "Consumer",
               "Effect": "Allow",
               "Action": [
                   "kinesis:DescribeStreamConsumer",
                   "kinesis:SubscribeToShard"
               ],
               "Resource": [
                   "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream/consumer/my-efo-flink-app",
                   "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream/consumer/my-efo-flink-app:*"
               ]
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert aws-kinesis-analytics-java-apps-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Wählen Sie unter Eigenschaften die Option Gruppe erstellen aus.

5. Geben Sie die folgenden Eigenschaften und Werte der Anwendung ein:

   Gruppen-ID	Schlüssel	Wert
   ConsumerConfigProperties	flink.stream.recordpublisher	EFO
   ConsumerConfigProperties	flink.stream.efo.consumername	basic-efo-flink-app
   ConsumerConfigProperties	INPUT_STREAM	ExampleInputStream
   ConsumerConfigProperties	flink.inputstream.initpos	LATEST
   ConsumerConfigProperties	AWS_REGION	us-west-2

6. Wählen Sie unter Eigenschaften die Option Gruppe erstellen aus.

7. Geben Sie die folgenden Eigenschaften und Werte der Anwendung ein:

   Gruppen-ID	Schlüssel	Wert
   ProducerConfigProperties	OUTPUT_STREAM	ExampleOutputStream
   ProducerConfigProperties	AWS_REGION	us-west-2
   ProducerConfigProperties	AggregationEnabled	false

8. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

9. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

10. Wählen Sie Aktualisieren.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. wählen Sie im Bereich Managed Service for Apache Flink die Option. MyApplication

3. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

4. Wählen Sie auf der Kinesis-Streams-Seite die ExampleOutputStream, wählen Sie Aktionen, wählen Sie Löschen und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

7. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

8. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.

1. Erstellen Sie eine Datei stock.py mit dem folgenden Inhalt:

    import datetime
       import json
       import random
       import boto3
   
       STREAM_NAME = "ExampleInputStream"
   
   
       def get_data():
           return {
               'event_time': datetime.datetime.now().isoformat(),
               'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
               'price': round(random.random() * 100, 2)}
   
   
       def generate(stream_name, kinesis_client):
           while True:
               data = get_data()
               print(data)
               kinesis_client.put_record(
                   StreamName=stream_name,
                   Data=json.dumps(data),
                   PartitionKey="partitionkey")
   
   
       if __name__ == '__main__':
           generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2'))

2. Führen Sie das stock.pySkript aus:

   $ python stock.py

   Lassen Sie das Skript laufen, während Sie den Rest des Tutorials abschließen.

1. Klonen Sie das Remote-Repository mit dem folgenden Befehl:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

2. Navigieren Sie zum amazon-kinesis-data-analytics-java-examples/FirehoseSink Verzeichnis .

1. Installieren Sie Java und Maven, wenn das noch nicht geschehen ist. Weitere Informationen finden Sie unter Erfüllen Sie die erforderlichen Voraussetzungen im Tutorial: Erste Schritte mit dem DataStream API integrierten Managed Service für Apache Flink Tutorial.

2. Um den Kinesis-Konnektor für die folgende Anwendung verwenden zu können, müssen Sie Apache Maven herunterladen, erstellen und installieren. Weitere Informationen finden Sie unter Verwenden des Apache Flink Kinesis Streams Connectors mit früheren Apache Flink-Versionen.

3. Kompilieren Sie die Anwendung mit dem folgenden Befehl:

   mvn package -Dflink.version=1.15.3

   Anmerkung

   Der bereitgestellte Quellcode basiert auf Bibliotheken von Java 11.

So laden Sie den Anwendungscode hoch

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie in der Konsole die Option ka-app-code -<username>Bucket und wählen Sie dann Upload aus.

3. Klicken Sie im Schritt Auswählen von Dateien auf Hinzufügen von Dateien. Navigieren Sie zu der java-getting-started-1.0.jarDatei, die Sie im vorherigen Schritt erstellt haben.

4. Sie müssen keine der Einstellungen für das Objekt ändern. Wählen Sie daher Hochladen.

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie im Dashboard Managed Service für Apache Flink die Option Analyseanwendung erstellen aus.

3. Geben Sie auf der Seite Managed Service für Apache Flink – Anwendung erstellen die Anwendungsdetails wie folgt ein:

   • Geben Sie als Anwendungsname ein MyApplication.

   • Geben Sie für Beschreibung den Text My java test app ein.

   • Wählen Sie für Laufzeit die Option Apache Flink aus.

     Anmerkung

     Managed Service für Apache Flink verwendet Apache Flink Version 1.15.2.

   • Belassen Sie den Versions-Pulldown bei Apache Flink Version 1.15.2 (empfohlene Version).

4. Wählen Sie für Zugriffsberechtigungen die Option Rolle erstellen/aktualisieren. IAM kinesis-analytics-MyApplication-us-west-2

5. Wählen Sie Create application aus.

1. Öffnen Sie die IAM Konsole unter. https://console.aws.amazon.com/iam/

2. Wählen Sie Policies (Richtlinien). Wählen Sie die kinesis-analytics-service-MyApplication-us-west-2-Richtlinie aus, die die Konsole im vorherigen Abschnitt für Sie erstellt hat.

3. Wählen Sie auf der Seite Summary (Übersicht) die Option Edit policy (Richtlinie bearbeiten) aus. Wählen Sie die JSONRegisterkarte.

4. Fügen Sie den markierten Abschnitt der folgenden Beispielrichtlinie der Richtlinie hinzu. Ersetzen Sie alle Instanzen des Beispielkontos IDs (012345678901) mit Ihrer Konto-ID.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/java-getting-started-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
              ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteDeliveryStream",
               "Effect": "Allow",
               "Action": "firehose:*",
               "Resource": "arn:aws:firehose:us-west-2:012345678901:deliverystream/ExampleDeliveryStream"
           }
       ]
   }

1. Wählen Sie auf der MyApplicationSeite Configure aus.

2. Klicken Sie auf der Seite Configure application (Anwendung konfigurieren) auf die Option Code location (Codespeicherort):

   • Geben Sie für Amazon-S3-Bucket ka-app-code-<username> ein.

   • Geben Sie als Pfad zum Amazon-S3-Objekt den Wert java-getting-started-1.0.jar ein.

3. Wählen Sie unter Zugriff auf Anwendungsressourcen für Zugriffsberechtigungen die Option IAMRolle erstellen/aktualisieren auskinesis-analytics-MyApplication-us-west-2.

4. Stellen Sie unter Überwachung sicher, dass die Ebene der Überwachungsmetriken auf Anwendung eingestellt ist.

5. Wählen Sie für die CloudWatch Protokollierung das Kontrollkästchen Aktivieren aus.

6. Wählen Sie Aktualisieren.

So erstellen Sie eine IAM-Rolle

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie im Navigationsbereich Roles (Rollen) und Create Role (Rolle erstellen) aus.

3. Wählen Sie unter Typ der vertrauenswürdigen Entität auswählen die Option AWS -Service aus. Wählen Sie unter Choose the service that will use this role (Wählen Sie den Service aus, der diese Rolle verwendet) die Option Kinesis aus. Wählen Sie unter Select your use case (Wählen Sie Ihren Anwendungsfall aus) die Option Kinesis Analytics aus.

   Wählen Sie Weiter: Berechtigungen aus.

4. Wählen Sie auf der Seite Attach permissions policies (Berechtigungsrichtlinien hinzufügen) Next: Review (Weiter: Überprüfen) aus. Sie fügen Berechtigungsrichtlinien an, nachdem Sie die Rolle erstellt haben.

5. Geben Sie auf der Seite Create role (Rolle erstellen) den Text MF-stream-rw-role für Role name (Rollenname) ein. Wählen Sie Rolle erstellen.

   Jetzt haben Sie eine neue IAM Rolle namens erstelltMF-stream-rw-role. Im nächsten Schritt aktualisieren Sie die Vertrauens- und Berechtigungsrichtlinien für die Rolle.

6. Fügen Sie die Berechtigungsrichtlinie der Rolle an.

   Anmerkung

   Für diese Übung übernimmt Managed Service für Apache Flink diese Rolle sowohl für das Lesen von Daten aus einem Kinesis-Datenstrom (Quelle) als auch zum Schreiben der Ausgabedaten in einen anderen Kinesis-Datenstrom. Daher fügen Sie die Richtlinie an, die Sie im vorherigen Schritt erstellt haben, Erstellen einer Berechtigungsrichtlinie.

   1. Wählen Sie auf der Seite Summary (Übersicht) die Registerkarte Permissions (Berechtigungen) aus.

   2. Wählen Sie Attach Policies (Richtlinien anfügen) aus.

   3. Geben Sie im Suchfeld AKReadSourceStreamWriteSinkStream (die Richtlinie, die Sie im vorhergehenden Abschnitt erstellt haben) ein.

   4. Wählen Sie die AKReadSourceStreamWriteSinkStreamRichtlinie und anschließend Richtlinie anhängen aus.

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namencreate_request.json. Ersetzen Sie die Beispielrolle ARN durch die ARN für die Rolle, die Sie zuvor erstellt haben. Ersetzen Sie das ARN Bucket-Suffix durch das Suffix, das Sie im Erstellen Sie abhängige Ressourcen Abschnitt (ka-app-code-<username>.) ausgewählt haben Ersetzen Sie die Beispielkonto-ID (012345678901) in der Rolle „Dienstausführung“ durch Ihre Konto-ID.

   {
       "ApplicationName": "test",
       "ApplicationDescription": "my java test app",
       "RuntimeEnvironment": "FLINK-1_15",
       "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
       "ApplicationConfiguration": {
           "ApplicationCodeConfiguration": {
               "CodeContent": {
                   "S3ContentLocation": {
                       "BucketARN": "arn:aws:s3:::ka-app-code-username",
                       "FileKey": "java-getting-started-1.0.jar"
                   }
               },
               "CodeContentType": "ZIPFILE"
           }
         }
       }
   }
   
   

2. Führen Sie die CreateApplication-Aktion mit der vorherigen Anforderung zum Erstellen der Anwendung aus:

   aws kinesisanalyticsv2 create-application --cli-input-json file://create_request.json

So starten Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstart_request.json.

   {
       "ApplicationName": "test",
       "RunConfiguration": {
           "ApplicationRestoreConfiguration": { 
            "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
            }
       }
   }
   

2. Führen Sie die StartApplication-Aktion mit der vorherigen Anforderung zum Starten der Anwendung aus:

   aws kinesisanalyticsv2 start-application --cli-input-json file://start_request.json

So stoppen Sie die Anwendung

1. Speichern Sie den folgenden JSON Code in einer Datei mit dem Namenstop_request.json.

   
   {
       "ApplicationName": "test"
   }
   

2. Führen Sie die StopApplication-Aktion mit der folgenden Anforderung zum Stoppen der Anwendung aus:

   aws kinesisanalyticsv2 stop-application --cli-input-json file://stop_request.json

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter /flink https://console.aws.amazon.com

2. Wählen Sie im Bereich Managed Service für Apache Flink die Option. MyApplication

3. Wählen Sie Konfigurieren aus.

4. Wählen Sie im Abschnitt Snapshots die Option Deaktivieren und anschließend Aktualisieren aus.

5. Wählen Sie auf der Seite der Anwendung die Option Löschen aus und bestätigen Sie den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen Sie im Bereich Kinesis Data Streams die Option ExampleInputStream.

3. Wählen Sie auf der ExampleInputStreamSeite Delete Kinesis Stream aus und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com/kinesis.

2. Wählen ExampleDeliveryStreamSie im Firehose-Bedienfeld.

3. Wählen Sie auf der ExampleDeliveryStreamSeite Delete Firehose stream und bestätigen Sie dann den Löschvorgang.

1. Öffnen Sie die Amazon S3 S3-Konsole unter https://console.aws.amazon.com/s3/.

2. Wählen Sie ka-app-code -<username> Eimer.

3. Wählen Sie Löschen und geben Sie dann den Bucketnamen ein, um das Löschen zu bestätigen.

4. Wenn Sie einen Amazon S3 S3-Bucket für das Ziel Ihres Firehose-Streams erstellt haben, löschen Sie auch diesen Bucket.

1. Öffnen Sie die IAM Konsole unter https://console.aws.amazon.com/iam/.

2. Wählen Sie in der Navigationsleiste Policies aus.

3. Geben Sie in der Filtersteuerung Kinesis ein.

4. Wählen Sie die Richtlinie kinesis-analytics-service- MyApplication -us-west-2.

5. Klicken Sie auf Richtlinienaktionen und anschließend auf Löschen.

6. Wenn Sie eine neue Richtlinie für Ihren Firehose-Stream erstellt haben, löschen Sie auch diese Richtlinie.

7. Wählen Sie in der Navigationsleiste Roles (Rollen) aus.

8. Wählen Sie die Rolle kinesis-analytics- MyApplication -us-west-2.

9. Wählen Sie dann Rolle löschen und bestätigen Sie das Löschen.

10. Wenn Sie eine neue Rolle für Ihren Firehose-Stream erstellt haben, löschen Sie auch diese Rolle.

1. Öffnen Sie die CloudWatch Konsole unter https://console.aws.amazon.com/cloudwatch/.

2. Wählen Sie in der Navigationsleiste Protokolle aus.

3. Wählen Sie die Gruppe/aws/kinesis-analytics/MyApplicationlog aus.

4. Wählen Sie dann Protokollgruppe löschen und bestätigen Sie das Löschen.