Input - Servizio gestito da Amazon per Apache Flink

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Input

Quando si configura l'input di applicazione per un'applicazione Kinesis Data Analytics basata su SQL, è necessario specificare l'origine di streaming, il nome del flusso nell'applicazione che viene creata e la mappatura tra i due.

Indice

InputSchema

Descrive il formato dei dati nell'origine di streaming e come ciascun elemento dati viene mappato alle colonne corrispondenti del flusso nell'applicazione che viene creato.

Inoltre utilizzato per descrivere il formato dell'origine dati di riferimento.

Tipo: oggetto SourceSchema

Campo obbligatorio: sì

NamePrefix

Il prefisso del nome da utilizzare quando si crea un flusso nell'applicazione. Supponi di specificare il prefisso "MyInApplicationStream". Kinesis Data Analytics crea uno o più (in base al conteggio InputParallelism specificato) flussi nell'applicazione con nomi "MyInApplicationStream_001", "MyInApplicationStream_002" e così via.

Tipo: stringa

Limitazioni di lunghezza: lunghezza minima pari a 1. La lunghezza massima è 32 caratteri.

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

Campo obbligatorio: sì

InputParallelism

Descrive il numero di flussi nell'applicazione da creare.

Tipo: oggetto InputParallelism

Campo obbligatorio: no

InputProcessingConfiguration

Il InputProcessingConfiguration per l'input. Un processore di input trasforma i record ricevuti dal flusso prima dell'esecuzione del codice SQL dell'applicazione. Al momento l'unica configurazione di elaborazione di input disponibile è InputLambdaProcessor.

Tipo: oggetto InputProcessingConfiguration

Campo obbligatorio: no

KinesisFirehoseInput

Se l'origine di streaming è un flusso di distribuzione di Amazon Kinesis Data Firehose, identifica l'ARN del flusso di consegna.

Tipo: oggetto KinesisFirehoseInput

Campo obbligatorio: no

KinesisStreamsInput

Se l'origine di streaming è un flusso di dati di Amazon Kinesis, identifica l'Amazon Resource Name (ARN) del flusso.

Tipo: oggetto KinesisStreamsInput

Campo obbligatorio: no

Vedi anche

Per ulteriori informazioni sull'utilizzo di questa API in una delle lingue specifiche AWS SDKs, consulta quanto segue: