Konfigurieren der Anwendungsausgabe - Entwicklerhandbuch für Amazon Kinesis Data Analytics for SQL Applications
Erstellen einer -Ausgabe mit der AWS CLI

Für neue Projekte empfehlen wir, den neuen Managed Service für Apache Flink Studio anstelle von Kinesis Data Analytics for SQL Applications zu verwenden. Der Managed Service für Apache Flink Studio kombiniert Benutzerfreundlichkeit mit fortschrittlichen Analysefunktionen, sodass Sie in wenigen Minuten anspruchsvolle Anwendungen zur Stream-Verarbeitung erstellen können.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Konfigurieren der Anwendungsausgabe

In Ihrem Anwendungs-Code schreiben Sie SQL-Anweisungen für die Ausgabe zu einem oder mehreren In-Application-Streams. Sie können Ihrer Anwendung optional eine Ausgabekonfiguration hinzufügen. , um alles, was in einen In-Application-Stream geschrieben wird, an ein externes Ziel wie einen Amazon Kinesis-Datenstrom, einen Firehose-Bereitstellungsdatenstrom oder eine - AWS Lambda Funktion zu speichern.

Es gibt eine Begrenzung für die Anzahl der externen Ziele, an die Sie eine Anwendungsausgabe weiterleiten können. Weitere Informationen finden Sie unter Einschränkungen.

Anmerkung

Wir empfehlen die Verwendung eines externen Ziels, an das die Daten aus dem In-Application-Fehler-Stream weitergeleitet werden, damit Sie die Fehler untersuchen können.

In jeder dieser Ausgabekonfigurationen stellen Sie Folgendes bereit:

  • Name des In-Application-Streams – Der Stream, den Sie an ein externes Ziel weiterleiten möchten.

    Kinesis Data Analytics sucht nach dem In-Application-Stream, den Sie in der Ausgabekonfiguration angegeben haben. (Bei der Eingabe des Stream-Namens muss die Groß- und Kleinschreibung beachtet werden. Die Eingabe muss daher genau sein). Stellen Sie sicher, dass Ihr Anwendungs-Code diesen In-Application-Stream erstellt.

  • Externes Ziel – Sie können Daten in einem Kinesis-Datenstrom, einem Firehose-Bereitstellungsdatenstrom oder einer Lambda-Funktion speichern. Sie stellen den Amazon-Ressourcennamen (ARN) des Streams oder der Funktion bereit. Sie stellen außerdem eine IAM-Rolle bereit, die Kinesis Data Analytics übernehmen kann, um in Ihrem Namen in den Stream oder schreiben oder Funktionen auszuführen. Sie beschreiben das Datensatzformat (JSON, CSV), das Kinesis Data Analytics beim Schreiben in das externe Ziel verwenden soll.

Wenn Kinesis Data Analytics nicht in das Streaming- oder Lambda-Ziel schreiben kann, führt der Service für unbegrenzte Zeit Versuche aus. Dies führt zu einer hohen Auslastung und Ihre Anwendung fällt zurück. Wenn dieses Problem nicht behoben wird, verarbeitet Ihre Anwendung ab einem gewissen Zeitpunkt keine neuen Daten mehr. Sie können Amazon Kinesis Analytics-Metriken überwachen und Alarmen für Ausfälle festlegen. Weitere Informationen zu Metriken und Alarmen finden Sie unter Verwenden von Amazon CloudWatch-Metriken und Erstellen von Amazon CloudWatch-Alarmen.

Sie können die Anwendungsausgabe mittels der AWS Management Consolekonfigurieren. Die Konsole führt den API-Aufruf aus, um die Konfiguration zu speichern.

Erstellen einer -Ausgabe mit der AWS CLI

In diesem Abschnitt wird beschrieben, wie der Abschnitt Outputs des Anforderungstextes für eine CreateApplication- oder AddApplicationOutput-Operation erstellt wird.

Erstellen einer Kinesis Stream-Ausgabe

Das folgende JSON-Fragment zeigt den Abschnitt Outputs im CreateApplication-Anforderungstext zum Erstellen eines Ziels für den Amazon Kinesis-Datenstrom.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisStreamsOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
 
]

Erstellen einer Firehose-Bereitstellungs-Stream-Ausgabe

Das folgende JSON-Fragment zeigt den -OutputsAbschnitt im CreateApplication Anforderungstext zum Erstellen eines Amazon-Data-Firehose-Bereitstellungsdatenstromziels.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisFirehoseOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]

Erstellen einer Lambda-Funktion

Das folgende JSON-Fragment zeigt den -OutputsAbschnitt im CreateApplication Anforderungstext zum Erstellen eines - AWS Lambda Funktionsziels.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "LambdaOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]