AddApplicationReferenceDataSource - Entwicklerhandbuch für Amazon Kinesis Data Analytics for SQL Applications

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.

AddApplicationReferenceDataSource

Anmerkung

Diese Dokumentation bezieht sich auf Version 1 der Amazon-Kinesis-Data-Analytics-API, die nur SQL-Anwendungen unterstützt. Version 2 der API unterstützt SQL- und Java-Anwendungen. Weitere Informationen zu Version 2 finden Sie in der Amazon-Kinesis-Data-Analytics-API-V2-Dokumentation.

Fügt einer bestehenden Anwendung eine Referenzdatenquelle hinzu.

Amazon-Kinesis-Analytics liest Referenzdaten (d. h. ein Amazon-S3-Objekt) und erstellt eine In-Application-Tabelle innerhalb Ihrer Anwendung. In der Anforderung geben Sie die Quelle (S3-Bucket-Name und Objektschlüsselname), den Namen der zu erstellenden In-Application-Tabelle und die notwendigen Zuordnungsinformationen an. Diese beschreiben, wie Daten im Amazon-S3-Objekt auf Spalten in der resultierenden In-Application-Tabelle abgebildet werden.

Konzeptuelle Informationen finden Sie unter Konfiguration des Anwendungseingangs. Die Begrenzungen der Datenquellen, die Sie Ihrer Anwendung hinzufügen können, finden Sie unter Begrenzungen.

Diese Operation erfordert zur Ausführung der kinesisanalytics:AddApplicationOutput-Aktion Berechtigungen.

Anforderungssyntax

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "ReferenceDataSource": { "ReferenceSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "S3ReferenceDataSource": { "BucketARN": "string", "FileKey": "string", "ReferenceRoleARN": "string" }, "TableName": "string" } }

Anforderungsparameter

Die Anforderung akzeptiert die folgenden Daten im JSON-Format.

ApplicationName

Name einer bestehenden Anwendung.

Typ: Zeichenfolge

Längenbeschränkungen: Minimale Länge beträgt 1 Zeichen. Maximale Länge beträgt 128 Zeichen.

Pattern: [a-zA-Z0-9_.-]+

Erforderlich: Ja

CurrentApplicationVersionId

Version der Anwendung, für die Sie die Referenzdatenquelle hinzufügen. Sie können den DescribeApplicationVorgang verwenden, um die aktuelle Anwendungsversion abzurufen. Wenn die angegebene Version nicht die aktuelle Version ist, wird ConcurrentModificationException zurückgegeben.

Type: Long

Gültiger Bereich: Mindestwert 1. Maximaler Wert von 999999999.

Erforderlich: Ja

ReferenceDataSource

Die Referenzdatenquelle kann ein Objekt in Ihrem Amazon-S3-Bucket sein. Amazon-Kinesis-Analytics liest das Objekt und kopiert die Daten in die erstellte In-Application-Tabelle. Sie stellen einen S3-Bucket, den Namen des Objektschlüssels und die daraus resultierende In-Applikation-Tabelle bereit. Sie müssen einer IAM-Rolle außerdem Berechtigungen geben, die Amazon-Kinesis-Analytics annehmen kann, um das Objekt in Ihrem S3-Bucket in Ihrem Namen zu lesen.

Typ: ReferenceDataSource Objekt

Erforderlich: Ja

Antwortelemente

Wenn die Aktion erfolgreich ist, gibt der Dienst eine HTTP 200-Antwort mit leerem HTTP-Textinhalt zurück.

Fehler

ConcurrentModificationException

Ausnahme, die als Ergebnis einer gleichzeitigen Änderung an einer Anwendung ausgelöst wurde. Beispiel: Zwei Personen versuchen, dieselbe Anwendung gleichzeitig zu bearbeiten.

HTTP Status Code: 400

InvalidArgumentException

Der angegebene Eingabeparameterwert ist ungültig.

HTTP Status Code: 400

ResourceInUseException

Die Anwendung ist für diesen Vorgang nicht verfügbar.

HTTP Status Code: 400

ResourceNotFoundException

Die angegebene Anwendung kann nicht gefunden werden.

HTTP Status Code: 400

UnsupportedOperationException

Die Anfrage wurde abgelehnt, weil ein bestimmter Parameter nicht unterstützt wird oder eine angegebene Ressource für diesen Vorgang nicht gültig ist.

HTTP Status Code: 400

Weitere Informationen finden Sie unter:

Weitere Informationen zur Verwendung dieser API in einem der sprachspezifischen AWS SDKs finden Sie im Folgenden: