View a markdown version of this page

AddApplicationInputProcessingConfiguration - Amazon Managed Service per Apache Flink (in precedenza Amazon Kinesis Data Analytics 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à.

AddApplicationInputProcessingConfiguration

Aggiunge un InputProcessingConfiguration a un'applicazione SQL-based Kinesis Data Analytics. Un processore di input pre-elabora i record nel flusso di input prima dell'esecuzione del codice SQL dell'applicazione. Al momento, l'unico processore di input disponibile è Amazon Lambda.

Sintassi della richiesta

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "InputId": "string", "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } } }

Parametri della richiesta

La richiesta accetta i seguenti dati in formato JSON.

ApplicationName

Il nome dell'applicazione a cui si desidera aggiungere la configurazione di elaborazione dell'input.

Tipo: stringa

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

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

Obbligatorio: sì

CurrentApplicationVersionId

La versione dell'applicazione a cui si desidera aggiungere la configurazione di elaborazione dell'input. È possibile utilizzare l'DescribeApplicationoperazione per ottenere la versione corrente dell'applicazione. Se la versione specificata non è la versione corrente, viene restituito ConcurrentModificationException.

Tipo: long

Intervallo valido: valore minimo di 1. Valore massimo di 999.999.999.

Obbligatorio: sì

InputId

L'ID della configurazione di input a cui aggiungere la configurazione di elaborazione dell'input. È possibile ottenere un elenco degli ID di input per un'applicazione utilizzando l'DescribeApplicationoperazione.

Tipo: stringa

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

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

Obbligatorio: sì

InputProcessingConfiguration

InputProcessingConfigurationDa aggiungere all'applicazione.

Tipo: oggetto InputProcessingConfiguration

Obbligatorio: sì

Sintassi della risposta

{ "ApplicationARN": "string", "ApplicationVersionId": number, "InputId": "string", "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "ResourceARN": "string", "RoleARN": "string" } } }

Elementi di risposta

Se l'operazione riesce, il servizio restituisce una risposta HTTP 200.

I dati seguenti vengono restituiti in formato JSON mediante il servizio.

ApplicationARN

Il nome della risorsa Amazon (ARN) dell'applicazione.

Tipo: stringa

Limitazioni di lunghezza: lunghezza minima di 1. La lunghezza massima è 2048 caratteri.

Modello: arn:.*

ApplicationVersionId

Fornisce la versione corrente dell'applicazione.

Tipo: long

Intervallo valido: valore minimo di 1. Valore massimo di 999.999.999.

InputId

L'ID di input associato all'input dell'applicazione. Questo è l'ID che Kinesis Data Analytics assegna a ogni configurazione di input aggiunta all'applicazione.

Tipo: stringa

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

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

InputProcessingConfigurationDescription

La descrizione del preprocessore che viene eseguito sui record in questo input prima dell'esecuzione del codice dell'applicazione.

Tipo: oggetto InputProcessingConfigurationDescription

Errori

ConcurrentModificationException

Eccezione generata a seguito di modifiche simultanee a un'applicazione. Questo errore può essere il risultato del tentativo di modificare un'applicazione senza utilizzare l'ID dell'applicazione corrente.

Codice di stato HTTP: 400

InvalidArgumentException

Il valore del parametro di input specificato non è valido.

Codice di stato HTTP: 400

InvalidRequestException

Il JSON della richiesta non è valido per l'operazione.

Codice di stato HTTP: 400

ResourceInUseException

L'applicazione non è disponibile per questa operazione.

Codice di stato HTTP: 400

ResourceNotFoundException

L'applicazione specificata non è stata trovata.

Codice di stato HTTP: 400

Vedi anche

Per ulteriori informazioni sull'utilizzo di questa API in uno degli AWS SDK specifici della lingua, consulta quanto segue: