AddApplicationInput - Amazon Managed Service para Apache Flink (anteriormente Amazon Kinesis Data Analytics para Apache Flink)

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

AddApplicationInput

Añade una fuente de streaming a su aplicación Kinesis Data Analytics basada en SQL.

Puede agregar un origen de transmisión cuando crea una aplicación o puede utilizar esta operación para agregar un origen de transmisión después de crear una aplicación. Para obtener más información, consulte CreateApplication.

Cualquier actualización de la configuración, incluida la adición de un origen de transmisión con esta operación, da lugar a una nueva versión de la aplicación. Puede utilizar la operación DescribeApplication para buscar la versión actual de la aplicación.

Sintaxis de la solicitud

{ "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" } }

Parámetros de la solicitud

La solicitud acepta los siguientes datos en formato JSON.

ApplicationName

El nombre de la aplicación existente a la cual desea agregar el origen de transmisión.

Tipo: string

Limitaciones de longitud: longitud mínima de 1. Longitud máxima de 128.

Patrón: [a-zA-Z0-9_.-]+

Obligatorio: sí

CurrentApplicationVersionId

La versión actual de la aplicación. Debe proporcionar el ApplicationVersionID o el ConditionalToken. Puede utilizar la operación DescribeApplication para buscar la versión actual de la aplicación.

Tipo: largo

Rango válido: valor mínimo de 1. Valor máximo de 999999999.

Obligatorio: sí

Input

El Input se va a agregar.

Tipo: objeto Input

Obligatorio: sí

Sintaxis de la respuesta

{ "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" } ] }

Elementos de respuesta

Si la acción se realiza correctamente, el servicio devuelve una respuesta HTTP 200.

El servicio devuelve los datos siguientes en formato JSON.

ApplicationARN

El nombre de recurso de Amazon (ARN) de la aplicación.

Tipo: string

Limitaciones de longitud: longitud mínima de 1. La longitud máxima es de 2048 caracteres.

Patrón: arn:.*

ApplicationVersionId

Otorga la versión actual de la aplicación.

Tipo: largo

Rango válido: valor mínimo de 1. Valor máximo de 999 999 999.

InputDescriptions

Describe la configuración de entrada de la aplicación.

Tipo: matriz de objetos InputDescription

Errores

CodeValidationException

El código de la aplicación proporcionado por el usuario (consulta) no es válido. Puede tratarse de un simple error de sintaxis.

Código de estado HTTP: 400

ConcurrentModificationException

Excepción que se produce como resultado de modificaciones simultáneas en una aplicación. El error puede deberse a un intento de modificar una aplicación sin utilizar el ID de la aplicación actual.

Código de estado HTTP: 400

InvalidArgumentException

El valor del parámetro de entrada especificado no es válido.

Código de estado HTTP: 400

InvalidRequestException

El JSON de la solicitud no es válido para la operación.

Código de estado HTTP: 400

ResourceInUseException

La aplicación no está disponible para esta operación.

Código de estado HTTP: 400

ResourceNotFoundException

No se encuentra la aplicación especificada.

Código de estado HTTP: 400

Véase también

Para obtener más información sobre el uso de esta API en uno de los AWS SDK específicos del idioma, consulte lo siguiente: