AnalyticsApplication

Provides a Kinesis Analytics Application resource. Kinesis Analytics is a managed service that allows processing and analyzing streaming data using standard SQL.

For more details, see the Amazon Kinesis Analytics Documentation.

Example Usage

using Pulumi;
using Aws = Pulumi.Aws;

class MyStack : Stack
{
    public MyStack()
    {
        var testStream = new Aws.Kinesis.Stream("testStream", new Aws.Kinesis.StreamArgs
        {
            ShardCount = 1,
        });
        var testApplication = new Aws.Kinesis.AnalyticsApplication("testApplication", new Aws.Kinesis.AnalyticsApplicationArgs
        {
            Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
            {
                KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
                {
                    ResourceArn = testStream.Arn,
                    RoleArn = aws_iam_role.Test.Arn,
                },
                NamePrefix = "test_prefix",
                Parallelism = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsParallelismArgs
                {
                    Count = 1,
                },
                Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
                {
                    RecordColumns = 
                    {
                        new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                        {
                            Mapping = "$.test",
                            Name = "test",
                            SqlType = "VARCHAR(8)",
                        },
                    },
                    RecordEncoding = "UTF-8",
                    RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
                    {
                        MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                        {
                            Json = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs
                            {
                                RecordRowPath = "$",
                            },
                        },
                    },
                },
            },
        });
    }

}

package main

import (
    "fmt"

    "github.com/pulumi/pulumi-aws/sdk/v2/go/aws/kinesis"
    "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)

func main() {
    pulumi.Run(func(ctx *pulumi.Context) error {
        testStream, err := kinesis.NewStream(ctx, "testStream", &kinesis.StreamArgs{
            ShardCount: pulumi.Int(1),
        })
        if err != nil {
            return err
        }
        _, err = kinesis.NewAnalyticsApplication(ctx, "testApplication", &kinesis.AnalyticsApplicationArgs{
            Inputs: &kinesis.AnalyticsApplicationInputsArgs{
                KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
                    ResourceArn: testStream.Arn,
                    RoleArn:     pulumi.String(aws_iam_role.Test.Arn),
                },
                NamePrefix: pulumi.String("test_prefix"),
                Parallelism: &kinesis.AnalyticsApplicationInputsParallelismArgs{
                    Count: pulumi.Int(1),
                },
                Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
                    RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
                        &kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
                            Mapping: pulumi.String(fmt.Sprintf("%v%v", "$", ".test")),
                            Name:    pulumi.String("test"),
                            SqlType: pulumi.String("VARCHAR(8)"),
                        },
                    },
                    RecordEncoding: pulumi.String("UTF-8"),
                    RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
                        MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
                            Json: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs{
                                RecordRowPath: pulumi.String("$"),
                            },
                        },
                    },
                },
            },
        })
        if err != nil {
            return err
        }
        return nil
    })
}

import pulumi
import pulumi_aws as aws

test_stream = aws.kinesis.Stream("testStream", shard_count=1)
test_application = aws.kinesis.AnalyticsApplication("testApplication", inputs={
    "kinesisStream": {
        "resource_arn": test_stream.arn,
        "role_arn": aws_iam_role["test"]["arn"],
    },
    "name_prefix": "test_prefix",
    "parallelism": {
        "count": 1,
    },
    "schema": {
        "recordColumns": [{
            "mapping": "$.test",
            "name": "test",
            "sqlType": "VARCHAR(8)",
        }],
        "recordEncoding": "UTF-8",
        "recordFormat": {
            "mappingParameters": {
                "json": {
                    "recordRowPath": "$",
                },
            },
        },
    },
})

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const testStream = new aws.kinesis.Stream("test_stream", {
    shardCount: 1,
});
const testApplication = new aws.kinesis.AnalyticsApplication("test_application", {
    inputs: {
        kinesisStream: {
            resourceArn: testStream.arn,
            roleArn: aws_iam_role_test.arn,
        },
        namePrefix: "test_prefix",
        parallelism: {
            count: 1,
        },
        schema: {
            recordColumns: [{
                mapping: "$.test",
                name: "test",
                sqlType: "VARCHAR(8)",
            }],
            recordEncoding: "UTF-8",
            recordFormat: {
                mappingParameters: {
                    json: {
                        recordRowPath: "$",
                    },
                },
            },
        },
    },
});

Create a AnalyticsApplication Resource

new AnalyticsApplication(name: string, args?: AnalyticsApplicationArgs, opts?: CustomResourceOptions);

def AnalyticsApplication(resource_name, opts=None, cloudwatch_logging_options=None, code=None, description=None, inputs=None, name=None, outputs=None, reference_data_sources=None, tags=None, __props__=None);

func NewAnalyticsApplication(ctx *Context, name string, args *AnalyticsApplicationArgs, opts ...ResourceOption) (*AnalyticsApplication, error)

public AnalyticsApplication(string name, AnalyticsApplicationArgs? args = null, CustomResourceOptions? opts = null)

name string: The unique name of the resource.
args AnalyticsApplicationArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

resource_name str: The unique name of the resource.
opts ResourceOptions: A bag of options that control this resource's behavior.

ctx Context: Context object for the current deployment.
name string: The unique name of the resource.
args AnalyticsApplicationArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

name string: The unique name of the resource.
args AnalyticsApplicationArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

AnalyticsApplication Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Programming Model docs.

Inputs

The AnalyticsApplication resource accepts the following input properties:

CloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptionsArgs: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
Code string: SQL Code to transform input data, and generate output.
Description string: Description of the application.
Inputs AnalyticsApplicationInputsArgs: Input configuration of the application. See Inputs below for more details.
Name string: Name of the Kinesis Analytics Application.
Outputs List<AnalyticsApplicationOutputArgs>: Output destination configuration of the application. See Outputs below for more details.
ReferenceDataSources AnalyticsApplicationReferenceDataSourcesArgs: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
Tags Dictionary<string, string>: Key-value map of tags for the Kinesis Analytics Application.

CloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptions: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
Code string: SQL Code to transform input data, and generate output.
Description string: Description of the application.
Inputs AnalyticsApplicationInputs: Input configuration of the application. See Inputs below for more details.
Name string: Name of the Kinesis Analytics Application.
Outputs []AnalyticsApplicationOutput: Output destination configuration of the application. See Outputs below for more details.
ReferenceDataSources AnalyticsApplicationReferenceDataSources: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
Tags map[string]string: Key-value map of tags for the Kinesis Analytics Application.

cloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptions: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
code string: SQL Code to transform input data, and generate output.
description string: Description of the application.
inputs AnalyticsApplicationInputs: Input configuration of the application. See Inputs below for more details.
name string: Name of the Kinesis Analytics Application.
outputs AnalyticsApplicationOutput[]: Output destination configuration of the application. See Outputs below for more details.
referenceDataSources AnalyticsApplicationReferenceDataSources: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
tags {[key: string]: string}: Key-value map of tags for the Kinesis Analytics Application.

cloudwatch_logging_options Dict[AnalyticsApplicationCloudwatchLoggingOptions]: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
code str: SQL Code to transform input data, and generate output.
description str: Description of the application.
inputs Dict[AnalyticsApplicationInputs]: Input configuration of the application. See Inputs below for more details.
name str: Name of the Kinesis Analytics Application.
outputs List[AnalyticsApplicationOutput]: Output destination configuration of the application. See Outputs below for more details.
reference_data_sources Dict[AnalyticsApplicationReferenceDataSources]: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
tags Dict[str, str]: Key-value map of tags for the Kinesis Analytics Application.

Outputs

All input properties are implicitly available as output properties. Additionally, the AnalyticsApplication resource produces the following output properties:

Arn string: The ARN of the Kinesis Analytics Appliation.
CreateTimestamp string: The Timestamp when the application version was created.
Id string: The provider-assigned unique ID for this managed resource.
LastUpdateTimestamp string: The Timestamp when the application was last updated.
Status string: The Status of the application.
Version int: The Version of the application.

Arn string: The ARN of the Kinesis Analytics Appliation.
CreateTimestamp string: The Timestamp when the application version was created.
Id string: The provider-assigned unique ID for this managed resource.
LastUpdateTimestamp string: The Timestamp when the application was last updated.
Status string: The Status of the application.
Version int: The Version of the application.

arn ARN: The ARN of the Kinesis Analytics Appliation.
createTimestamp string: The Timestamp when the application version was created.
id string: The provider-assigned unique ID for this managed resource.
lastUpdateTimestamp string: The Timestamp when the application was last updated.
status string: The Status of the application.
version number: The Version of the application.

arn str: The ARN of the Kinesis Analytics Appliation.
create_timestamp str: The Timestamp when the application version was created.
id str: The provider-assigned unique ID for this managed resource.
last_update_timestamp str: The Timestamp when the application was last updated.
status str: The Status of the application.
version float: The Version of the application.

Look up an Existing AnalyticsApplication Resource

Get an existing AnalyticsApplication resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

public static get(name: string, id: Input<ID>, state?: AnalyticsApplicationState, opts?: CustomResourceOptions): AnalyticsApplication

static get(resource_name, id, opts=None, arn=None, cloudwatch_logging_options=None, code=None, create_timestamp=None, description=None, inputs=None, last_update_timestamp=None, name=None, outputs=None, reference_data_sources=None, status=None, tags=None, version=None, __props__=None);

func GetAnalyticsApplication(ctx *Context, name string, id IDInput, state *AnalyticsApplicationState, opts ...ResourceOption) (*AnalyticsApplication, error)

public static AnalyticsApplication Get(string name, Input<string> id, AnalyticsApplicationState? state, CustomResourceOptions? opts = null)

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

resource_name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

The following state arguments are supported:

Arn string: The ARN of the Kinesis Analytics Appliation.
CloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptionsArgs: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
Code string: SQL Code to transform input data, and generate output.
CreateTimestamp string: The Timestamp when the application version was created.
Description string: Description of the application.
Inputs AnalyticsApplicationInputsArgs: Input configuration of the application. See Inputs below for more details.
LastUpdateTimestamp string: The Timestamp when the application was last updated.
Name string: Name of the Kinesis Analytics Application.
Outputs List<AnalyticsApplicationOutputArgs>: Output destination configuration of the application. See Outputs below for more details.
ReferenceDataSources AnalyticsApplicationReferenceDataSourcesArgs: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
Status string: The Status of the application.
Tags Dictionary<string, string>: Key-value map of tags for the Kinesis Analytics Application.
Version int: The Version of the application.

Arn string: The ARN of the Kinesis Analytics Appliation.
CloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptions: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
Code string: SQL Code to transform input data, and generate output.
CreateTimestamp string: The Timestamp when the application version was created.
Description string: Description of the application.
Inputs AnalyticsApplicationInputs: Input configuration of the application. See Inputs below for more details.
LastUpdateTimestamp string: The Timestamp when the application was last updated.
Name string: Name of the Kinesis Analytics Application.
Outputs []AnalyticsApplicationOutput: Output destination configuration of the application. See Outputs below for more details.
ReferenceDataSources AnalyticsApplicationReferenceDataSources: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
Status string: The Status of the application.
Tags map[string]string: Key-value map of tags for the Kinesis Analytics Application.
Version int: The Version of the application.

arn ARN: The ARN of the Kinesis Analytics Appliation.
cloudwatchLoggingOptions AnalyticsApplicationCloudwatchLoggingOptions: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
code string: SQL Code to transform input data, and generate output.
createTimestamp string: The Timestamp when the application version was created.
description string: Description of the application.
inputs AnalyticsApplicationInputs: Input configuration of the application. See Inputs below for more details.
lastUpdateTimestamp string: The Timestamp when the application was last updated.
name string: Name of the Kinesis Analytics Application.
outputs AnalyticsApplicationOutput[]: Output destination configuration of the application. See Outputs below for more details.
referenceDataSources AnalyticsApplicationReferenceDataSources: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
status string: The Status of the application.
tags {[key: string]: string}: Key-value map of tags for the Kinesis Analytics Application.
version number: The Version of the application.

arn str: The ARN of the Kinesis Analytics Appliation.
cloudwatch_logging_options Dict[AnalyticsApplicationCloudwatchLoggingOptions]: The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.
code str: SQL Code to transform input data, and generate output.
create_timestamp str: The Timestamp when the application version was created.
description str: Description of the application.
inputs Dict[AnalyticsApplicationInputs]: Input configuration of the application. See Inputs below for more details.
last_update_timestamp str: The Timestamp when the application was last updated.
name str: Name of the Kinesis Analytics Application.
outputs List[AnalyticsApplicationOutput]: Output destination configuration of the application. See Outputs below for more details.
reference_data_sources Dict[AnalyticsApplicationReferenceDataSources]: An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
status str: The Status of the application.
tags Dict[str, str]: Key-value map of tags for the Kinesis Analytics Application.
version float: The Version of the application.

Supporting Types

AnalyticsApplicationCloudwatchLoggingOptions

LogStreamArn string: The ARN of the CloudWatch Log Stream.
RoleArn string: The ARN of the IAM Role used to send application messages.
Id string: The ARN of the Kinesis Analytics Application.

LogStreamArn string: The ARN of the CloudWatch Log Stream.
RoleArn string: The ARN of the IAM Role used to send application messages.
Id string: The ARN of the Kinesis Analytics Application.

logStreamArn string: The ARN of the CloudWatch Log Stream.
roleArn string: The ARN of the IAM Role used to send application messages.
id string: The ARN of the Kinesis Analytics Application.

logStreamArn str: The ARN of the CloudWatch Log Stream.
role_arn str: The ARN of the IAM Role used to send application messages.
id str: The ARN of the Kinesis Analytics Application.

AnalyticsApplicationInputs

NamePrefix string: The Name Prefix to use when creating an in-application stream.
Schema AnalyticsApplicationInputsSchemaArgs: The Schema format of the data in the streaming source. See Source Schema below for more details.
Id string: The ARN of the Kinesis Analytics Application.
KinesisFirehose AnalyticsApplicationInputsKinesisFirehoseArgs: The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
KinesisStream AnalyticsApplicationInputsKinesisStreamArgs: The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
Parallelism AnalyticsApplicationInputsParallelismArgs: The number of Parallel in-application streams to create. See Parallelism below for more details.
ProcessingConfiguration AnalyticsApplicationInputsProcessingConfigurationArgs: The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
StartingPositionConfigurations List<AnalyticsApplicationInputsStartingPositionConfigurationArgs>
StreamNames List<string>

NamePrefix string: The Name Prefix to use when creating an in-application stream.
Schema AnalyticsApplicationInputsSchema: The Schema format of the data in the streaming source. See Source Schema below for more details.
Id string: The ARN of the Kinesis Analytics Application.
KinesisFirehose AnalyticsApplicationInputsKinesisFirehose: The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
KinesisStream AnalyticsApplicationInputsKinesisStream: The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
Parallelism AnalyticsApplicationInputsParallelism: The number of Parallel in-application streams to create. See Parallelism below for more details.
ProcessingConfiguration AnalyticsApplicationInputsProcessingConfiguration: The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
StartingPositionConfigurations []AnalyticsApplicationInputsStartingPositionConfiguration
StreamNames []string

namePrefix string: The Name Prefix to use when creating an in-application stream.
schema AnalyticsApplicationInputsSchema: The Schema format of the data in the streaming source. See Source Schema below for more details.
id string: The ARN of the Kinesis Analytics Application.
kinesisFirehose AnalyticsApplicationInputsKinesisFirehose: The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
kinesisStream AnalyticsApplicationInputsKinesisStream: The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
parallelism AnalyticsApplicationInputsParallelism: The number of Parallel in-application streams to create. See Parallelism below for more details.
processingConfiguration AnalyticsApplicationInputsProcessingConfiguration: The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
startingPositionConfigurations AnalyticsApplicationInputsStartingPositionConfiguration[]
streamNames string[]

name_prefix str: The Name Prefix to use when creating an in-application stream.
schema Dict[AnalyticsApplicationInputsSchema]: The Schema format of the data in the streaming source. See Source Schema below for more details.
id str: The ARN of the Kinesis Analytics Application.
kinesisFirehose Dict[AnalyticsApplicationInputsKinesisFirehose]: The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
kinesisStream Dict[AnalyticsApplicationInputsKinesisStream]: The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
parallelism Dict[AnalyticsApplicationInputsParallelism]: The number of Parallel in-application streams to create. See Parallelism below for more details.
processingConfiguration Dict[AnalyticsApplicationInputsProcessingConfiguration]: The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
startingPositionConfigurations List[AnalyticsApplicationInputsStartingPositionConfiguration]
streamNames List[str]

AnalyticsApplicationInputsKinesisFirehose

ResourceArn string: The ARN of the Kinesis Firehose delivery stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

ResourceArn string: The ARN of the Kinesis Firehose delivery stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

resourceArn string: The ARN of the Kinesis Firehose delivery stream.
roleArn string: The ARN of the IAM Role used to access the stream.

resource_arn str: The ARN of the Kinesis Firehose delivery stream.
role_arn str: The ARN of the IAM Role used to access the stream.

AnalyticsApplicationInputsKinesisStream

ResourceArn string: The ARN of the Kinesis Stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

ResourceArn string: The ARN of the Kinesis Stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

resourceArn string: The ARN of the Kinesis Stream.
roleArn string: The ARN of the IAM Role used to access the stream.

resource_arn str: The ARN of the Kinesis Stream.
role_arn str: The ARN of the IAM Role used to access the stream.

AnalyticsApplicationInputsParallelism

Count int: The Count of streams.

Count int: The Count of streams.

count number: The Count of streams.

count float: The Count of streams.

AnalyticsApplicationInputsProcessingConfiguration

Lambda AnalyticsApplicationInputsProcessingConfigurationLambdaArgs: The Lambda function configuration. See Lambda below for more details.

Lambda AnalyticsApplicationInputsProcessingConfigurationLambda: The Lambda function configuration. See Lambda below for more details.

lambda AnalyticsApplicationInputsProcessingConfigurationLambda: The Lambda function configuration. See Lambda below for more details.

lambda Dict[AnalyticsApplicationInputsProcessingConfigurationLambda]: The Lambda function configuration. See Lambda below for more details.

AnalyticsApplicationInputsProcessingConfigurationLambda

ResourceArn string: The ARN of the Lambda function.
RoleArn string: The ARN of the IAM Role used to access the Lambda function.

ResourceArn string: The ARN of the Lambda function.
RoleArn string: The ARN of the IAM Role used to access the Lambda function.

resourceArn string: The ARN of the Lambda function.
roleArn string: The ARN of the IAM Role used to access the Lambda function.

resource_arn str: The ARN of the Lambda function.
role_arn str: The ARN of the IAM Role used to access the Lambda function.

AnalyticsApplicationInputsSchema

RecordColumns List<AnalyticsApplicationInputsSchemaRecordColumnArgs>: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
RecordFormat AnalyticsApplicationInputsSchemaRecordFormatArgs: The Record Format and mapping information to schematize a record. See Record Format below for more details.
RecordEncoding string: The Encoding of the record in the streaming source.

RecordColumns []AnalyticsApplicationInputsSchemaRecordColumn: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
RecordFormat AnalyticsApplicationInputsSchemaRecordFormat: The Record Format and mapping information to schematize a record. See Record Format below for more details.
RecordEncoding string: The Encoding of the record in the streaming source.

recordColumns AnalyticsApplicationInputsSchemaRecordColumn[]: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
recordFormat AnalyticsApplicationInputsSchemaRecordFormat: The Record Format and mapping information to schematize a record. See Record Format below for more details.
recordEncoding string: The Encoding of the record in the streaming source.

recordColumns List[AnalyticsApplicationInputsSchemaRecordColumn]: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
recordFormat Dict[AnalyticsApplicationInputsSchemaRecordFormat]: The Record Format and mapping information to schematize a record. See Record Format below for more details.
recordEncoding str: The Encoding of the record in the streaming source.

AnalyticsApplicationInputsSchemaRecordColumn

Name string: Name of the column.
SqlType string: The SQL Type of the column.
Mapping string: The Mapping reference to the data element.

Name string: Name of the column.
SqlType string: The SQL Type of the column.
Mapping string: The Mapping reference to the data element.

name string: Name of the column.
sqlType string: The SQL Type of the column.
mapping string: The Mapping reference to the data element.

name str: Name of the column.
sqlType str: The SQL Type of the column.
mapping str: The Mapping reference to the data element.

AnalyticsApplicationInputsSchemaRecordFormat

MappingParameters AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs: The Mapping Information for the record format. See Mapping Parameters below for more details.
RecordFormatType string: The type of Record Format. Can be CSV or JSON.

MappingParameters AnalyticsApplicationInputsSchemaRecordFormatMappingParameters: The Mapping Information for the record format. See Mapping Parameters below for more details.
RecordFormatType string: The type of Record Format. Can be CSV or JSON.

mappingParameters AnalyticsApplicationInputsSchemaRecordFormatMappingParameters: The Mapping Information for the record format. See Mapping Parameters below for more details.
recordFormatType string: The type of Record Format. Can be CSV or JSON.

mappingParameters Dict[AnalyticsApplicationInputsSchemaRecordFormatMappingParameters]: The Mapping Information for the record format. See Mapping Parameters below for more details.
recordFormatType str: The type of Record Format. Can be CSV or JSON.

AnalyticsApplicationInputsSchemaRecordFormatMappingParameters

Csv AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
Json AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

Csv AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsv: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
Json AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJson: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

csv AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsv: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
json AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJson: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

csv Dict[AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsv]: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
json Dict[AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJson]: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsv

RecordColumnDelimiter string: The Column Delimiter.
RecordRowDelimiter string: The Row Delimiter.

RecordColumnDelimiter string: The Column Delimiter.
RecordRowDelimiter string: The Row Delimiter.

recordColumnDelimiter string: The Column Delimiter.
recordRowDelimiter string: The Row Delimiter.

recordColumnDelimiter str: The Column Delimiter.
recordRowDelimiter str: The Row Delimiter.

AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJson

RecordRowPath string: Path to the top-level parent that contains the records.

RecordRowPath string: Path to the top-level parent that contains the records.

recordRowPath string: Path to the top-level parent that contains the records.

recordRowPath str: Path to the top-level parent that contains the records.

AnalyticsApplicationInputsStartingPositionConfiguration

StartingPosition string

StartingPosition string

startingPosition string

starting_position str

AnalyticsApplicationOutput

Name string: The Name of the in-application stream.
Schema AnalyticsApplicationOutputSchemaArgs: The Schema format of the data written to the destination. See Destination Schema below for more details.
Id string: The ARN of the Kinesis Analytics Application.
KinesisFirehose AnalyticsApplicationOutputKinesisFirehoseArgs: The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
KinesisStream AnalyticsApplicationOutputKinesisStreamArgs: The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
Lambda AnalyticsApplicationOutputLambdaArgs: The Lambda function destination. See Lambda below for more details.

Name string: The Name of the in-application stream.
Schema AnalyticsApplicationOutputSchema: The Schema format of the data written to the destination. See Destination Schema below for more details.
Id string: The ARN of the Kinesis Analytics Application.
KinesisFirehose AnalyticsApplicationOutputKinesisFirehose: The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
KinesisStream AnalyticsApplicationOutputKinesisStream: The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
Lambda AnalyticsApplicationOutputLambda: The Lambda function destination. See Lambda below for more details.

name string: The Name of the in-application stream.
schema AnalyticsApplicationOutputSchema: The Schema format of the data written to the destination. See Destination Schema below for more details.
id string: The ARN of the Kinesis Analytics Application.
kinesisFirehose AnalyticsApplicationOutputKinesisFirehose: The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
kinesisStream AnalyticsApplicationOutputKinesisStream: The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
lambda AnalyticsApplicationOutputLambda: The Lambda function destination. See Lambda below for more details.

name str: The Name of the in-application stream.
schema Dict[AnalyticsApplicationOutputSchema]: The Schema format of the data written to the destination. See Destination Schema below for more details.
id str: The ARN of the Kinesis Analytics Application.
kinesisFirehose Dict[AnalyticsApplicationOutputKinesisFirehose]: The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
kinesisStream Dict[AnalyticsApplicationOutputKinesisStream]: The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
lambda Dict[AnalyticsApplicationOutputLambda]: The Lambda function destination. See Lambda below for more details.

AnalyticsApplicationOutputKinesisFirehose

ResourceArn string: The ARN of the Kinesis Firehose delivery stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

ResourceArn string: The ARN of the Kinesis Firehose delivery stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

resourceArn string: The ARN of the Kinesis Firehose delivery stream.
roleArn string: The ARN of the IAM Role used to access the stream.

resource_arn str: The ARN of the Kinesis Firehose delivery stream.
role_arn str: The ARN of the IAM Role used to access the stream.

AnalyticsApplicationOutputKinesisStream

ResourceArn string: The ARN of the Kinesis Stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

ResourceArn string: The ARN of the Kinesis Stream.
RoleArn string: The ARN of the IAM Role used to access the stream.

resourceArn string: The ARN of the Kinesis Stream.
roleArn string: The ARN of the IAM Role used to access the stream.

resource_arn str: The ARN of the Kinesis Stream.
role_arn str: The ARN of the IAM Role used to access the stream.

AnalyticsApplicationOutputLambda

ResourceArn string: The ARN of the Lambda function.
RoleArn string: The ARN of the IAM Role used to access the Lambda function.

ResourceArn string: The ARN of the Lambda function.
RoleArn string: The ARN of the IAM Role used to access the Lambda function.

resourceArn string: The ARN of the Lambda function.
roleArn string: The ARN of the IAM Role used to access the Lambda function.

resource_arn str: The ARN of the Lambda function.
role_arn str: The ARN of the IAM Role used to access the Lambda function.

AnalyticsApplicationOutputSchema

RecordFormatType string: The Format Type of the records on the output stream. Can be CSV or JSON.

RecordFormatType string: The Format Type of the records on the output stream. Can be CSV or JSON.

recordFormatType string: The Format Type of the records on the output stream. Can be CSV or JSON.

recordFormatType str: The Format Type of the records on the output stream. Can be CSV or JSON.

AnalyticsApplicationReferenceDataSources

S3 AnalyticsApplicationReferenceDataSourcesS3Args: The S3 configuration for the reference data source. See S3 Reference below for more details.
Schema AnalyticsApplicationReferenceDataSourcesSchemaArgs: The Schema format of the data in the streaming source. See Source Schema below for more details.
TableName string: The in-application Table Name.
Id string: The ARN of the Kinesis Analytics Application.

S3 AnalyticsApplicationReferenceDataSourcesS3: The S3 configuration for the reference data source. See S3 Reference below for more details.
Schema AnalyticsApplicationReferenceDataSourcesSchema: The Schema format of the data in the streaming source. See Source Schema below for more details.
TableName string: The in-application Table Name.
Id string: The ARN of the Kinesis Analytics Application.

s3 AnalyticsApplicationReferenceDataSourcesS3: The S3 configuration for the reference data source. See S3 Reference below for more details.
schema AnalyticsApplicationReferenceDataSourcesSchema: The Schema format of the data in the streaming source. See Source Schema below for more details.
tableName string: The in-application Table Name.
id string: The ARN of the Kinesis Analytics Application.

s3 Dict[AnalyticsApplicationReferenceDataSourcesS3]: The S3 configuration for the reference data source. See S3 Reference below for more details.
schema Dict[AnalyticsApplicationReferenceDataSourcesSchema]: The Schema format of the data in the streaming source. See Source Schema below for more details.
table_name str: The in-application Table Name.
id str: The ARN of the Kinesis Analytics Application.

AnalyticsApplicationReferenceDataSourcesS3

BucketArn string: The S3 Bucket ARN.
FileKey string: The File Key name containing reference data.
RoleArn string: The ARN of the IAM Role used to send application messages.

BucketArn string: The S3 Bucket ARN.
FileKey string: The File Key name containing reference data.
RoleArn string: The ARN of the IAM Role used to send application messages.

bucketArn string: The S3 Bucket ARN.
fileKey string: The File Key name containing reference data.
roleArn string: The ARN of the IAM Role used to send application messages.

bucketArn str: The S3 Bucket ARN.
fileKey str: The File Key name containing reference data.
role_arn str: The ARN of the IAM Role used to send application messages.

AnalyticsApplicationReferenceDataSourcesSchema

RecordColumns List<AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs>: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
RecordFormat AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs: The Record Format and mapping information to schematize a record. See Record Format below for more details.
RecordEncoding string: The Encoding of the record in the streaming source.

RecordColumns []AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
RecordFormat AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat: The Record Format and mapping information to schematize a record. See Record Format below for more details.
RecordEncoding string: The Encoding of the record in the streaming source.

recordColumns AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn[]: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
recordFormat AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat: The Record Format and mapping information to schematize a record. See Record Format below for more details.
recordEncoding string: The Encoding of the record in the streaming source.

recordColumns List[AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn]: The Record Column mapping for the streaming source data element. See Record Columns below for more details.
recordFormat Dict[AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat]: The Record Format and mapping information to schematize a record. See Record Format below for more details.
recordEncoding str: The Encoding of the record in the streaming source.

AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn

Name string: Name of the column.
SqlType string: The SQL Type of the column.
Mapping string: The Mapping reference to the data element.

Name string: Name of the column.
SqlType string: The SQL Type of the column.
Mapping string: The Mapping reference to the data element.

name string: Name of the column.
sqlType string: The SQL Type of the column.
mapping string: The Mapping reference to the data element.

name str: Name of the column.
sqlType str: The SQL Type of the column.
mapping str: The Mapping reference to the data element.

AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat

MappingParameters AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs: The Mapping Information for the record format. See Mapping Parameters below for more details.
RecordFormatType string: The type of Record Format. Can be CSV or JSON.

MappingParameters AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters: The Mapping Information for the record format. See Mapping Parameters below for more details.
RecordFormatType string: The type of Record Format. Can be CSV or JSON.

mappingParameters AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters: The Mapping Information for the record format. See Mapping Parameters below for more details.
recordFormatType string: The type of Record Format. Can be CSV or JSON.

mappingParameters Dict[AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters]: The Mapping Information for the record format. See Mapping Parameters below for more details.
recordFormatType str: The type of Record Format. Can be CSV or JSON.

AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters

Csv AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
Json AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

Csv AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsv: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
Json AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJson: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

csv AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsv: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
json AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJson: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

csv Dict[AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsv]: Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
json Dict[AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJson]: Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsv

RecordColumnDelimiter string: The Column Delimiter.
RecordRowDelimiter string: The Row Delimiter.

RecordColumnDelimiter string: The Column Delimiter.
RecordRowDelimiter string: The Row Delimiter.

recordColumnDelimiter string: The Column Delimiter.
recordRowDelimiter string: The Row Delimiter.

recordColumnDelimiter str: The Column Delimiter.
recordRowDelimiter str: The Row Delimiter.

AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJson

RecordRowPath string: Path to the top-level parent that contains the records.

RecordRowPath string: Path to the top-level parent that contains the records.

recordRowPath string: Path to the top-level parent that contains the records.

recordRowPath str: Path to the top-level parent that contains the records.

Package Details

Repository: https://github.com/pulumi/pulumi-aws
License: Apache-2.0
Notes: This Pulumi package is based on the aws Terraform Provider.

The Pulumi Platform

Get Started

Migrate to Pulumi

Solutions for All Teams and Engineers

Any Code

Any Cloud