Für neue Projekte empfehlen wir, den neuen Managed Service für Apache Flink Studio anstelle von Kinesis-Data-Analytics-for-SQL-Anwendungen 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.
Input
Wenn Sie die Anwendungseingabe konfigurieren, geben Sie die Streaming-Quelle an, den Namen des In-Application-Streams, der erstellt wird, sowie die Zuordnung zwischen den beiden. Weitere Informationen finden Sie unter Konfigurieren der Anwendungseingabe.
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 zum Erstellen eines In-Application-Streams. Angenommen, Sie geben ein Präfix "“ anMyInApplicationStream. Amazon Kinesis Analytics erstellt dann einen oder mehrere (gemäß der von Ihnen angegebenen
InputParallelismAnzahl) anwendungsinterne Streams mit den Namen "MyInApplicationStream_001“, "MyInApplicationStream_002“ usw.Typ: Zeichenfolge
Längenbeschränkungen: Minimale Länge beträgt 1 Zeichen. Maximale Länge beträgt 32 Zeichen.
Erforderlich: Ja
- InputParallelism
-
Gibt die Anzahl der zu erstellenden In-Application-Streams an.
Die Daten aus Ihrer Quelle werden in diese In-Application-Eingabe-Streams geleitet.
(siehe Konfigurieren der Anwendungseingabe.
Typ: InputParallelism Objekt
Erforderlich: Nein
- InputProcessingConfiguration
-
Der für die Eingabe InputProcessingConfiguration. Ein Eingabeprozessor wandelt Datensätze um, sobald sie vom Stream empfangen werden, bevor der SQL-Code der Anwendung ausgeführt wird. Derzeit ist die einzige verfügbare Konfiguration für die Eingabeverarbeitung InputLambdaProcessor.
Typ: InputProcessingConfiguration Objekt
Erforderlich: Nein
- KinesisFirehoseInput
-
Identifiziert, wenn die Streaming-Quelle ein Amazon Kinesis Firehose-Delivery-Stream ist, den ARN des Delivery-Streams und eine IAM-Rolle, die Amazon Kinesis Analytics ermöglicht, für Sie auf den Stream zuzugreifen.
Hinweis: Entweder
KinesisStreamsInputoderKinesisFirehoseInputist erforderlich.Typ: KinesisFirehoseInput Objekt
Erforderlich: Nein
- KinesisStreamsInput
-
Identifiziert, wenn die Streaming-Quelle ein Amazon Kinesis-Stream ist, den Amazon Resource Name (ARN) des Streams und eine IAM-Rolle, die Amazon Kinesis Analytics ermöglicht, für Sie auf den Stream zuzugreifen.
Hinweis: Entweder
KinesisStreamsInputoderKinesisFirehoseInputist erforderlich.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:
