AddApplicationInput - Amazon Managed Service für Apache Flink (früher Amazon Kinesis Data Analytics für Apache Flink)

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.

AddApplicationInput

Fügt Ihrer SQL-basierten Kinesis Data Analytics Analytics-Anwendung eine Streaming-Quelle hinzu.

Sie können eine Streaming-Quelle hinzufügen, wenn Sie eine Anwendung erstellen, oder Sie können diesen Vorgang verwenden, um eine Streaming-Quelle hinzuzufügen, nachdem Sie eine Anwendung erstellt haben. Weitere Informationen finden Sie unter CreateApplication.

Jedes Konfigurationsupdate, einschließlich dem Hinzufügen einer Streaming-Quelle mit dieser Operation, führt zu einer neuen Version der Anwendung. Mit der DescribeApplication-Operation können Sie die aktuelle Anwendungsversion ermitteln.

Anforderungssyntax

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "Input": { "InputParallelism": { "Count": number }, "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } }, "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "KinesisFirehoseInput": { "ResourceARN": "string" }, "KinesisStreamsInput": { "ResourceARN": "string" }, "NamePrefix": "string" } }

Anforderungsparameter

Die Anforderung akzeptiert die folgenden Daten im JSON-Format.

ApplicationName

Der Name Ihrer vorhandenen Anwendung, zu der Sie die Streaming-Quelle hinzufügen möchten.

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

Die aktuelle Version Ihrer Anwendung. Sie müssen das ApplicationVersionID oder angeben. ConditionalToken Sie können die DescribeApplication Operation verwenden, um die aktuelle Anwendungsversion zu finden.

Type: Long

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

Erforderlich: Ja

Input

Die Input hinzuzufügen.

Typ: Input Objekt

Erforderlich: Ja

Antwortsyntax

{ "ApplicationARN": "string", "ApplicationVersionId": number, "InputDescriptions": [ { "InAppStreamNames": [ "string" ], "InputId": "string", "InputParallelism": { "Count": number }, "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "ResourceARN": "string", "RoleARN": "string" } }, "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "string" }, "KinesisFirehoseInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "KinesisStreamsInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "NamePrefix": "string" } ] }

Antwortelemente

Wenn die Aktion erfolgreich ist, sendet der Service eine HTTP 200-Antwort zurück.

Die folgenden Daten werden vom Service im JSON-Format zurückgegeben.

ApplicationARN

Der Amazon-Ressourcenname (ARN) der Anwendung.

Typ: Zeichenfolge

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

Pattern: arn:.*

ApplicationVersionId

Gibt die aktuelle Anwendungsversion an.

Type: Long

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

InputDescriptions

Beschreibt die Konfiguration der Anwendungseingabe.

Typ: Array von InputDescription-Objekten

Fehler

CodeValidationException

Der vom Benutzer bereitgestellte Anwendungscode (Abfrage) ist ungültig. Dies kann ein einfacher Syntaxfehler sein.

HTTP Status Code: 400

ConcurrentModificationException

Ausnahme, die als Ergebnis gleichzeitiger Änderungen an einer Anwendung ausgelöst wurde. Dieser Fehler kann das Ergebnis des Versuchs sein, eine Anwendung zu ändern, ohne die aktuelle Anwendungs-ID zu verwenden.

HTTP Status Code: 400

InvalidArgumentException

Der angegebene Eingabeparameterwert ist nicht gültig.

HTTP Status Code: 400

InvalidRequestException

Die JSON-Anforderung ist für den Vorgang nicht gü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

Weitere Informationen finden Sie unter:

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