Updates an existing Amazon Kinesis Analytics application. Using this API, you can update application code, input configuration, and output configuration.
kinesisanalytics_update_application(ApplicationName,
CurrentApplicationVersionId, ApplicationUpdate)[required] Name of the Amazon Kinesis Analytics application to update.
[required] The current application version ID. You can use the DescribeApplication operation to get this value.
[required] Describes application updates.
svc$update_application(
ApplicationName = "string",
CurrentApplicationVersionId = 123,
ApplicationUpdate = list(
InputUpdates = list(
list(
InputId = "string",
NamePrefixUpdate = "string",
InputProcessingConfigurationUpdate = list(
InputLambdaProcessorUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
)
),
KinesisStreamsInputUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
),
KinesisFirehoseInputUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
),
InputSchemaUpdate = list(
RecordFormatUpdate = list(
RecordFormatType = "JSON"|"CSV",
MappingParameters = list(
JSONMappingParameters = list(
RecordRowPath = "string"
),
CSVMappingParameters = list(
RecordRowDelimiter = "string",
RecordColumnDelimiter = "string"
)
)
),
RecordEncodingUpdate = "string",
RecordColumnUpdates = list(
list(
Name = "string",
Mapping = "string",
SqlType = "string"
)
)
),
InputParallelismUpdate = list(
CountUpdate = 123
)
)
),
ApplicationCodeUpdate = "string",
OutputUpdates = list(
list(
OutputId = "string",
NameUpdate = "string",
KinesisStreamsOutputUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
),
KinesisFirehoseOutputUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
),
LambdaOutputUpdate = list(
ResourceARNUpdate = "string",
RoleARNUpdate = "string"
),
DestinationSchemaUpdate = list(
RecordFormatType = "JSON"|"CSV"
)
)
),
ReferenceDataSourceUpdates = list(
list(
ReferenceId = "string",
TableNameUpdate = "string",
S3ReferenceDataSourceUpdate = list(
BucketARNUpdate = "string",
FileKeyUpdate = "string",
ReferenceRoleARNUpdate = "string"
),
ReferenceSchemaUpdate = 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"
)
)
)
)
),
CloudWatchLoggingOptionUpdates = list(
list(
CloudWatchLoggingOptionId = "string",
LogStreamARNUpdate = "string",
RoleARNUpdate = "string"
)
)
)
)
Note that Amazon Kinesis Analytics updates the
CurrentApplicationVersionId each time you update your application.
This operation requires permission for the
kinesisanalytics:UpdateApplication action.