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à.
AddApplicationInput
Aggiunge una sorgente di streaming all'applicazione Kinesis Data Analytics basata su SQL.
Puoi aggiungere una sorgente di streaming quando crei un'applicazione oppure puoi usare questa operazione per aggiungere una sorgente di streaming dopo aver creato un'applicazione. Per ulteriori informazioni, consulta CreateApplication.
Qualsiasi aggiornamento della configurazione, inclusa l'aggiunta di un'origine di streaming utilizzando questa operazione, genera una nuova versione dell'applicazione. Puoi utilizzare l'operazione DescribeApplication per individuare la versione dell'applicazione corrente.
Sintassi della richiesta
{
"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"
}
}Parametri della richiesta
La richiesta accetta i seguenti dati in formato JSON.
- ApplicationName
-
Il nome dell'applicazione esistente a cui desideri aggiungere la sorgente di streaming.
▬Tipo: stringa
Limitazioni di lunghezza: lunghezza minima pari a 1. La lunghezza massima è 128 caratteri.
Modello:
[a-zA-Z0-9_.-]+Campo obbligatorio: sì
- CurrentApplicationVersionId
-
La versione corrente dell'applicazione. È necessario fornire
ApplicationVersionIDo utilizzare l'ConditionalTokenDescribeApplicationoperazione per trovare la versione corrente dell'applicazione.Tipo: long
Intervallo valido: valore minimo di 1. Valore massimo di 999.999.999.
Campo obbligatorio: sì
- Input
-
Il Input da aggiungere.
Tipo: oggetto Input
Campo obbligatorio: sì
Sintassi della risposta
{
"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"
}
]
}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.
- InputDescriptions
-
Descrive la configurazione di input dell'applicazione.
Tipo: matrice di oggetti InputDescription
Errori
- CodeValidationException
-
Il codice dell'applicazione (query) fornito dall'utente non è valido. Può trattarsi di un semplice errore di sintassi.
Codice di stato HTTP: 400
- 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
-
La richiesta JSON non è valida 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:
