Skip to content

Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application

Description

Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor pre-processes records on the input stream before the application's SQL code executes. Currently, the only input processor available is Amazon Lambda.

Usage

kinesisanalyticsv2_add_application_input_processing_configuration(
  ApplicationName, CurrentApplicationVersionId, InputId,
  InputProcessingConfiguration)

Arguments

  • ApplicationName

[required] The name of the application to which you want to add the input processing configuration.

  • CurrentApplicationVersionId

[required] The version of the application to which you want to add the input processing configuration. You can use the describe_application operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

  • InputId

[required] The ID of the input configuration to add the input processing configuration to. You can get a list of the input IDs for an application using the describe_application operation.

  • InputProcessingConfiguration

[required] The InputProcessingConfiguration to add to the application.

Value

A list with the following syntax:

list(
  ApplicationARN = "string",
  ApplicationVersionId = 123,
  InputId = "string",
  InputProcessingConfigurationDescription = list(
    InputLambdaProcessorDescription = list(
      ResourceARN = "string",
      RoleARN = "string"
    )
  )
)

Request syntax

svc$add_application_input_processing_configuration(
  ApplicationName = "string",
  CurrentApplicationVersionId = 123,
  InputId = "string",
  InputProcessingConfiguration = list(
    InputLambdaProcessor = list(
      ResourceARN = "string"
    )
  )
)