paws.analytics (version 0.1.7)

kinesisanalyticsv2_add_application_input: Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application

Description

Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.

Usage

kinesisanalyticsv2_add_application_input(ApplicationName,
  CurrentApplicationVersionId, Input)

Arguments

ApplicationName

[required] The name of your existing application to which you want to add the streaming source.

CurrentApplicationVersionId

[required] The current version of your application. You can use the DescribeApplication operation to find the current application version.

Input

[required] The Input to add.

Request syntax

svc$add_application_input(
  ApplicationName = "string",
  CurrentApplicationVersionId = 123,
  Input = list(
    NamePrefix = "string",
    InputProcessingConfiguration = list(
      InputLambdaProcessor = list(
        ResourceARN = "string"
      )
    ),
    KinesisStreamsInput = list(
      ResourceARN = "string"
    ),
    KinesisFirehoseInput = list(
      ResourceARN = "string"
    ),
    InputParallelism = list(
      Count = 123
    ),
    InputSchema = list(
      RecordFormat = list(
        RecordFormatType = "JSON"|"CSV",
        MappingParameters = list(
          JSONMappingParameters = list(
            RecordRowPath = "string"
          ),
          CSVMappingParameters = list(
            RecordRowDelimiter = "string",
            RecordColumnDelimiter = "string"
          )
        )
      ),
      RecordEncoding = "string",
      RecordColumns = list(
        list(
          Name = "string",
          Mapping = "string",
          SqlType = "string"
        )
      )
    )
  )
)

Details

You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication.

Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the DescribeApplication operation to find the current application version.