Input - 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.

Input

Wenn Sie den Anwendungs-Input für eine SQL-basierte Kinesis Data Analytics-Anwendung konfigurieren, geben Sie die Streamingquelle, den Namen des erzeugten In-Application-Streams und die Zuordnung zwischen den beiden an.

Inhalt

InputSchema

Beschreibt das Format der Daten in der Streaming-Quelle und wie jedes Datenelement den entsprechenden Spalten im erzeugten In-Application-Stream zugeordnet wird.

Wird auch zum Beschreiben des Formats der Referenzdatenquelle verwendet.

Typ: SourceSchema Objekt

Erforderlich: Ja

NamePrefix

Das Namenspräfix, das beim Erstellen eines In-Application-Streams verwendet werden soll. Angenommen, Sie geben einen Präfix „MyInApplicationStream“ an. Kinesis Data Analytics erstellt dann einen oder mehrere (gemäß der von Ihnen angegebenen InputParallelism-Anzahl) In-Application-Streams mit den Namen „MyInApplicationStream_001“, „MyInApplicationStream_002“ und so weiter.

Typ: Zeichenfolge

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

Pattern: [^-\s<>&]*

Erforderlich: Ja

InputParallelism

Gibt die Anzahl der zu erstellenden In-Application-Streams an.

Typ: InputParallelism Objekt

Erforderlich: Nein

InputProcessingConfiguration

Das InputProcessingConfiguration für die Eingabe. Ein Eingabeprozessor wandelt Datensätze um, sobald sie vom Stream empfangen werden, bevor der SQL-Code der Anwendung ausgeführt wird. Derzeit ist als einzige Eingabeverarbeitungskonfiguration InputLambdaProcessor verfügbar.

Typ: InputProcessingConfiguration Objekt

Erforderlich: Nein

KinesisFirehoseInput

Wenn es sich bei der Streamingquelle um einen Amazon Kinesis Data Firehose Delivery-Stream handelt, wird der ARN des Delivery-Streams identifiziert.

Typ: KinesisFirehoseInput Objekt

Erforderlich: Nein

KinesisStreamsInput

Wenn es sich bei der Streamingquelle um einen Amazon Kinesis-Datenstrom handelt, wird der Amazon Resource Name (ARN) des Streams identifiziert.

Typ: KinesisStreamsInput Objekt

Erforderlich: Nein

Weitere Informationen finden Sie unter:

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