Amazon Kinesis Data Analytics Application Input
When you configure the application input, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.
Input is a property of the AWS::KinesisAnalytics::Application resource.
Syntax
To declare this entity in your AWS CloudFormation template, use the following syntax:
JSON
{ "NamePrefix" :String, "InputParallelism" : InputParallelism, "InputSchema" : InputSchema, "KinesisFirehoseInput" : KinesisFirehoseInput, "KinesisStreamsInput" : KinesisStreamsInput, "InputProcessingConfiguration : InputProcessingConfiguration }
YAML
NamePrefix:StringInputParallelism: InputParallelism InputSchema: InputSchema KinesisFirehoseInput: KinesisFirehoseInput KinesisStreamsInput: KinesisStreamsInput InputProcessingConfiguration: InputProcessingConfiguration
Properties
NamePrefix-
The name prefix to use when creating the in-application streams.
Required: Yes
Type: String
Update requires: No interruption
InputParallelism-
Describes the number of in-application streams to create.
Required: No
Type: Kinesis Data Analytics Application InputParallelism
Update requires: No interruption
InputSchema-
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
Required: Yes
Type: Kinesis Data Analytics Application InputSchema
Update requires: No interruption
KinesisFirehoseInput-
If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's Amazon Resource Name (ARN) and an IAM role that enables Kinesis Data Analytics to access the stream on your behalf.
Required: No
Type: Kinesis Data Analytics Application KinesisFirehoseInput
Update requires: No interruption
KinesisStreamsInput-
If the streaming source is an Amazon Kinesis stream, identifies the stream's ARN and an IAM role that enables Kinesis Data Analytics to access the stream on your behalf.
Required: No
Type: Kinesis Data Analytics Application KinesisStreamsInput
Update requires: No interruption
InputProcessingConfiguration-
The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is
InputLambdaProcessor.Required: No
Type: Kinesis Data Analytics Application InputProcessingConfiguration
Update requires: No interruption
