Add Application Input
kinesisanalyticsv2_add_application_input | R Documentation |
Adds a streaming source to your SQL-based Kinesis Data Analytics application¶
Description¶
Adds a streaming source to your SQL-based Kinesis Data Analytics application.
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 create_application
.
Any configuration update, including adding a streaming source using this
operation, results in a new version of the application. You can use the
describe_application
operation to find the current application
version.
Usage¶
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 must provide the
ApplicationVersionID
or theConditionalToken
.You can use thedescribe_application
operation to find the current application version.Input
[required] The Input to add.
Value¶
A list with the following syntax:
list(
ApplicationARN = "string",
ApplicationVersionId = 123,
InputDescriptions = list(
list(
InputId = "string",
NamePrefix = "string",
InAppStreamNames = list(
"string"
),
InputProcessingConfigurationDescription = list(
InputLambdaProcessorDescription = list(
ResourceARN = "string",
RoleARN = "string"
)
),
KinesisStreamsInputDescription = list(
ResourceARN = "string",
RoleARN = "string"
),
KinesisFirehoseInputDescription = list(
ResourceARN = "string",
RoleARN = "string"
),
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"
)
)
),
InputParallelism = list(
Count = 123
),
InputStartingPositionConfiguration = list(
InputStartingPosition = "NOW"|"TRIM_HORIZON"|"LAST_STOPPED_POINT"
)
)
)
)
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"
)
)
)
)
)