Docs Home Pulumi IaC Pulumi ESC Pulumi Cloud Packages Tutorials
  1. Packages
  2. AWS
  3. API Docs
  4. kinesis
  5. AnalyticsApplication
AWS v6.73.0 published on Wednesday, Mar 19, 2025 by Pulumi
pulumi/pulumi-aws

aws.kinesis.AnalyticsApplication

Explore with Pulumi AI

aws logo
AWS v6.73.0 published on Wednesday, Mar 19, 2025 by Pulumi
pulumi/pulumi-aws

    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.

    Note: To manage Amazon Kinesis Data Analytics for Apache Flink applications, use the aws.kinesisanalyticsv2.Application resource.

    Example Usage

    Kinesis Stream Input

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

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

    import pulumi
import pulumi_aws as aws

test_stream = aws.kinesis.Stream("test_stream",
    name="kinesis-test",
    shard_count=1)
test_application = aws.kinesis.AnalyticsApplication("test_application",
    name="kinesis-analytics-application-test",
    inputs={
        "name_prefix": "test_prefix",
        "kinesis_stream": {
            "resource_arn": test_stream.arn,
            "role_arn": test["arn"],
        },
        "parallelism": {
            "count": 1,
        },
        "schema": {
            "record_columns": [{
                "mapping": "$.test",
                "name": "test",
                "sql_type": "VARCHAR(8)",
            }],
            "record_encoding": "UTF-8",
            "record_format": {
                "mapping_parameters": {
                    "json": {
                        "record_row_path": "$",
                    },
                },
            },
        },
    })

    package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesis"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		testStream, err := kinesis.NewStream(ctx, "test_stream", &kinesis.StreamArgs{
			Name:       pulumi.String("kinesis-test"),
			ShardCount: pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		_, err = kinesis.NewAnalyticsApplication(ctx, "test_application", &kinesis.AnalyticsApplicationArgs{
			Name: pulumi.String("kinesis-analytics-application-test"),
			Inputs: &kinesis.AnalyticsApplicationInputsArgs{
				NamePrefix: pulumi.String("test_prefix"),
				KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
					ResourceArn: testStream.Arn,
					RoleArn:     pulumi.Any(test.Arn),
				},
				Parallelism: &kinesis.AnalyticsApplicationInputsParallelismArgs{
					Count: pulumi.Int(1),
				},
				Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
					RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
						&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
							Mapping: pulumi.String("$.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
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var testStream = new Aws.Kinesis.Stream("test_stream", new()
    {
        Name = "kinesis-test",
        ShardCount = 1,
    });

    var testApplication = new Aws.Kinesis.AnalyticsApplication("test_application", new()
    {
        Name = "kinesis-analytics-application-test",
        Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
        {
            NamePrefix = "test_prefix",
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
            {
                ResourceArn = testStream.Arn,
                RoleArn = test.Arn,
            },
            Parallelism = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsParallelismArgs
            {
                Count = 1,
            },
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
            {
                RecordColumns = new[]
                {
                    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 generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.kinesis.Stream;
import com.pulumi.aws.kinesis.StreamArgs;
import com.pulumi.aws.kinesis.AnalyticsApplication;
import com.pulumi.aws.kinesis.AnalyticsApplicationArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsKinesisStreamArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsParallelismArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var testStream = new Stream("testStream", StreamArgs.builder()
            .name("kinesis-test")
            .shardCount(1)
            .build());

        var testApplication = new AnalyticsApplication("testApplication", AnalyticsApplicationArgs.builder()
            .name("kinesis-analytics-application-test")
            .inputs(AnalyticsApplicationInputsArgs.builder()
                .namePrefix("test_prefix")
                .kinesisStream(AnalyticsApplicationInputsKinesisStreamArgs.builder()
                    .resourceArn(testStream.arn())
                    .roleArn(test.arn())
                    .build())
                .parallelism(AnalyticsApplicationInputsParallelismArgs.builder()
                    .count(1)
                    .build())
                .schema(AnalyticsApplicationInputsSchemaArgs.builder()
                    .recordColumns(AnalyticsApplicationInputsSchemaRecordColumnArgs.builder()
                        .mapping("$.test")
                        .name("test")
                        .sqlType("VARCHAR(8)")
                        .build())
                    .recordEncoding("UTF-8")
                    .recordFormat(AnalyticsApplicationInputsSchemaRecordFormatArgs.builder()
                        .mappingParameters(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs.builder()
                            .json(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs.builder()
                                .recordRowPath("$")
                                .build())
                            .build())
                        .build())
                    .build())
                .build())
            .build());

    }
}

    resources:
  testStream:
    type: aws:kinesis:Stream
    name: test_stream
    properties:
      name: kinesis-test
      shardCount: 1
  testApplication:
    type: aws:kinesis:AnalyticsApplication
    name: test_application
    properties:
      name: kinesis-analytics-application-test
      inputs:
        namePrefix: test_prefix
        kinesisStream:
          resourceArn: ${testStream.arn}
          roleArn: ${test.arn}
        parallelism:
          count: 1
        schema:
          recordColumns:
            - mapping: $.test
              name: test
              sqlType: VARCHAR(8)
          recordEncoding: UTF-8
          recordFormat:
            mappingParameters:
              json:
                recordRowPath: $

    Starting An Application

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

const example = new aws.cloudwatch.LogGroup("example", {name: "analytics"});
const exampleLogStream = new aws.cloudwatch.LogStream("example", {
    name: "example-kinesis-application",
    logGroupName: example.name,
});
const exampleStream = new aws.kinesis.Stream("example", {
    name: "example-kinesis-stream",
    shardCount: 1,
});
const exampleFirehoseDeliveryStream = new aws.kinesis.FirehoseDeliveryStream("example", {
    name: "example-kinesis-delivery-stream",
    destination: "extended_s3",
    extendedS3Configuration: {
        bucketArn: exampleAwsS3Bucket.arn,
        roleArn: exampleAwsIamRole.arn,
    },
});
const test = new aws.kinesis.AnalyticsApplication("test", {
    name: "example-application",
    cloudwatchLoggingOptions: {
        logStreamArn: exampleLogStream.arn,
        roleArn: exampleAwsIamRole.arn,
    },
    inputs: {
        namePrefix: "example_prefix",
        schema: {
            recordColumns: [{
                name: "COLUMN_1",
                sqlType: "INTEGER",
            }],
            recordFormat: {
                mappingParameters: {
                    csv: {
                        recordColumnDelimiter: ",",
                        recordRowDelimiter: "|",
                    },
                },
            },
        },
        kinesisStream: {
            resourceArn: exampleStream.arn,
            roleArn: exampleAwsIamRole.arn,
        },
        startingPositionConfigurations: [{
            startingPosition: "NOW",
        }],
    },
    outputs: [{
        name: "OUTPUT_1",
        schema: {
            recordFormatType: "CSV",
        },
        kinesisFirehose: {
            resourceArn: exampleFirehoseDeliveryStream.arn,
            roleArn: exampleAwsIamRole.arn,
        },
    }],
    startApplication: true,
});

    import pulumi
import pulumi_aws as aws

example = aws.cloudwatch.LogGroup("example", name="analytics")
example_log_stream = aws.cloudwatch.LogStream("example",
    name="example-kinesis-application",
    log_group_name=example.name)
example_stream = aws.kinesis.Stream("example",
    name="example-kinesis-stream",
    shard_count=1)
example_firehose_delivery_stream = aws.kinesis.FirehoseDeliveryStream("example",
    name="example-kinesis-delivery-stream",
    destination="extended_s3",
    extended_s3_configuration={
        "bucket_arn": example_aws_s3_bucket["arn"],
        "role_arn": example_aws_iam_role["arn"],
    })
test = aws.kinesis.AnalyticsApplication("test",
    name="example-application",
    cloudwatch_logging_options={
        "log_stream_arn": example_log_stream.arn,
        "role_arn": example_aws_iam_role["arn"],
    },
    inputs={
        "name_prefix": "example_prefix",
        "schema": {
            "record_columns": [{
                "name": "COLUMN_1",
                "sql_type": "INTEGER",
            }],
            "record_format": {
                "mapping_parameters": {
                    "csv": {
                        "record_column_delimiter": ",",
                        "record_row_delimiter": "|",
                    },
                },
            },
        },
        "kinesis_stream": {
            "resource_arn": example_stream.arn,
            "role_arn": example_aws_iam_role["arn"],
        },
        "starting_position_configurations": [{
            "starting_position": "NOW",
        }],
    },
    outputs=[{
        "name": "OUTPUT_1",
        "schema": {
            "record_format_type": "CSV",
        },
        "kinesis_firehose": {
            "resource_arn": example_firehose_delivery_stream.arn,
            "role_arn": example_aws_iam_role["arn"],
        },
    }],
    start_application=True)

    package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/cloudwatch"
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesis"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := cloudwatch.NewLogGroup(ctx, "example", &cloudwatch.LogGroupArgs{
			Name: pulumi.String("analytics"),
		})
		if err != nil {
			return err
		}
		exampleLogStream, err := cloudwatch.NewLogStream(ctx, "example", &cloudwatch.LogStreamArgs{
			Name:         pulumi.String("example-kinesis-application"),
			LogGroupName: example.Name,
		})
		if err != nil {
			return err
		}
		exampleStream, err := kinesis.NewStream(ctx, "example", &kinesis.StreamArgs{
			Name:       pulumi.String("example-kinesis-stream"),
			ShardCount: pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		exampleFirehoseDeliveryStream, err := kinesis.NewFirehoseDeliveryStream(ctx, "example", &kinesis.FirehoseDeliveryStreamArgs{
			Name:        pulumi.String("example-kinesis-delivery-stream"),
			Destination: pulumi.String("extended_s3"),
			ExtendedS3Configuration: &kinesis.FirehoseDeliveryStreamExtendedS3ConfigurationArgs{
				BucketArn: pulumi.Any(exampleAwsS3Bucket.Arn),
				RoleArn:   pulumi.Any(exampleAwsIamRole.Arn),
			},
		})
		if err != nil {
			return err
		}
		_, err = kinesis.NewAnalyticsApplication(ctx, "test", &kinesis.AnalyticsApplicationArgs{
			Name: pulumi.String("example-application"),
			CloudwatchLoggingOptions: &kinesis.AnalyticsApplicationCloudwatchLoggingOptionsArgs{
				LogStreamArn: exampleLogStream.Arn,
				RoleArn:      pulumi.Any(exampleAwsIamRole.Arn),
			},
			Inputs: &kinesis.AnalyticsApplicationInputsArgs{
				NamePrefix: pulumi.String("example_prefix"),
				Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
					RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
						&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
							Name:    pulumi.String("COLUMN_1"),
							SqlType: pulumi.String("INTEGER"),
						},
					},
					RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
						MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
							Csv: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs{
								RecordColumnDelimiter: pulumi.String(","),
								RecordRowDelimiter:    pulumi.String("|"),
							},
						},
					},
				},
				KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
					ResourceArn: exampleStream.Arn,
					RoleArn:     pulumi.Any(exampleAwsIamRole.Arn),
				},
				StartingPositionConfigurations: kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArray{
					&kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArgs{
						StartingPosition: pulumi.String("NOW"),
					},
				},
			},
			Outputs: kinesis.AnalyticsApplicationOutputTypeArray{
				&kinesis.AnalyticsApplicationOutputTypeArgs{
					Name: pulumi.String("OUTPUT_1"),
					Schema: &kinesis.AnalyticsApplicationOutputSchemaArgs{
						RecordFormatType: pulumi.String("CSV"),
					},
					KinesisFirehose: &kinesis.AnalyticsApplicationOutputKinesisFirehoseArgs{
						ResourceArn: exampleFirehoseDeliveryStream.Arn,
						RoleArn:     pulumi.Any(exampleAwsIamRole.Arn),
					},
				},
			},
			StartApplication: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = new Aws.CloudWatch.LogGroup("example", new()
    {
        Name = "analytics",
    });

    var exampleLogStream = new Aws.CloudWatch.LogStream("example", new()
    {
        Name = "example-kinesis-application",
        LogGroupName = example.Name,
    });

    var exampleStream = new Aws.Kinesis.Stream("example", new()
    {
        Name = "example-kinesis-stream",
        ShardCount = 1,
    });

    var exampleFirehoseDeliveryStream = new Aws.Kinesis.FirehoseDeliveryStream("example", new()
    {
        Name = "example-kinesis-delivery-stream",
        Destination = "extended_s3",
        ExtendedS3Configuration = new Aws.Kinesis.Inputs.FirehoseDeliveryStreamExtendedS3ConfigurationArgs
        {
            BucketArn = exampleAwsS3Bucket.Arn,
            RoleArn = exampleAwsIamRole.Arn,
        },
    });

    var test = new Aws.Kinesis.AnalyticsApplication("test", new()
    {
        Name = "example-application",
        CloudwatchLoggingOptions = new Aws.Kinesis.Inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs
        {
            LogStreamArn = exampleLogStream.Arn,
            RoleArn = exampleAwsIamRole.Arn,
        },
        Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
        {
            NamePrefix = "example_prefix",
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
            {
                RecordColumns = new[]
                {
                    new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                    {
                        Name = "COLUMN_1",
                        SqlType = "INTEGER",
                    },
                },
                RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
                {
                    MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                    {
                        Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs
                        {
                            RecordColumnDelimiter = ",",
                            RecordRowDelimiter = "|",
                        },
                    },
                },
            },
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
            {
                ResourceArn = exampleStream.Arn,
                RoleArn = exampleAwsIamRole.Arn,
            },
            StartingPositionConfigurations = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationInputsStartingPositionConfigurationArgs
                {
                    StartingPosition = "NOW",
                },
            },
        },
        Outputs = new[]
        {
            new Aws.Kinesis.Inputs.AnalyticsApplicationOutputArgs
            {
                Name = "OUTPUT_1",
                Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputSchemaArgs
                {
                    RecordFormatType = "CSV",
                },
                KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisFirehoseArgs
                {
                    ResourceArn = exampleFirehoseDeliveryStream.Arn,
                    RoleArn = exampleAwsIamRole.Arn,
                },
            },
        },
        StartApplication = true,
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.cloudwatch.LogGroup;
import com.pulumi.aws.cloudwatch.LogGroupArgs;
import com.pulumi.aws.cloudwatch.LogStream;
import com.pulumi.aws.cloudwatch.LogStreamArgs;
import com.pulumi.aws.kinesis.Stream;
import com.pulumi.aws.kinesis.StreamArgs;
import com.pulumi.aws.kinesis.FirehoseDeliveryStream;
import com.pulumi.aws.kinesis.FirehoseDeliveryStreamArgs;
import com.pulumi.aws.kinesis.inputs.FirehoseDeliveryStreamExtendedS3ConfigurationArgs;
import com.pulumi.aws.kinesis.AnalyticsApplication;
import com.pulumi.aws.kinesis.AnalyticsApplicationArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsKinesisStreamArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputKinesisFirehoseArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var example = new LogGroup("example", LogGroupArgs.builder()
            .name("analytics")
            .build());

        var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()
            .name("example-kinesis-application")
            .logGroupName(example.name())
            .build());

        var exampleStream = new Stream("exampleStream", StreamArgs.builder()
            .name("example-kinesis-stream")
            .shardCount(1)
            .build());

        var exampleFirehoseDeliveryStream = new FirehoseDeliveryStream("exampleFirehoseDeliveryStream", FirehoseDeliveryStreamArgs.builder()
            .name("example-kinesis-delivery-stream")
            .destination("extended_s3")
            .extendedS3Configuration(FirehoseDeliveryStreamExtendedS3ConfigurationArgs.builder()
                .bucketArn(exampleAwsS3Bucket.arn())
                .roleArn(exampleAwsIamRole.arn())
                .build())
            .build());

        var test = new AnalyticsApplication("test", AnalyticsApplicationArgs.builder()
            .name("example-application")
            .cloudwatchLoggingOptions(AnalyticsApplicationCloudwatchLoggingOptionsArgs.builder()
                .logStreamArn(exampleLogStream.arn())
                .roleArn(exampleAwsIamRole.arn())
                .build())
            .inputs(AnalyticsApplicationInputsArgs.builder()
                .namePrefix("example_prefix")
                .schema(AnalyticsApplicationInputsSchemaArgs.builder()
                    .recordColumns(AnalyticsApplicationInputsSchemaRecordColumnArgs.builder()
                        .name("COLUMN_1")
                        .sqlType("INTEGER")
                        .build())
                    .recordFormat(AnalyticsApplicationInputsSchemaRecordFormatArgs.builder()
                        .mappingParameters(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs.builder()
                            .csv(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs.builder()
                                .recordColumnDelimiter(",")
                                .recordRowDelimiter("|")
                                .build())
                            .build())
                        .build())
                    .build())
                .kinesisStream(AnalyticsApplicationInputsKinesisStreamArgs.builder()
                    .resourceArn(exampleStream.arn())
                    .roleArn(exampleAwsIamRole.arn())
                    .build())
                .startingPositionConfigurations(AnalyticsApplicationInputsStartingPositionConfigurationArgs.builder()
                    .startingPosition("NOW")
                    .build())
                .build())
            .outputs(AnalyticsApplicationOutputArgs.builder()
                .name("OUTPUT_1")
                .schema(AnalyticsApplicationOutputSchemaArgs.builder()
                    .recordFormatType("CSV")
                    .build())
                .kinesisFirehose(AnalyticsApplicationOutputKinesisFirehoseArgs.builder()
                    .resourceArn(exampleFirehoseDeliveryStream.arn())
                    .roleArn(exampleAwsIamRole.arn())
                    .build())
                .build())
            .startApplication(true)
            .build());

    }
}

    resources:
  example:
    type: aws:cloudwatch:LogGroup
    properties:
      name: analytics
  exampleLogStream:
    type: aws:cloudwatch:LogStream
    name: example
    properties:
      name: example-kinesis-application
      logGroupName: ${example.name}
  exampleStream:
    type: aws:kinesis:Stream
    name: example
    properties:
      name: example-kinesis-stream
      shardCount: 1
  exampleFirehoseDeliveryStream:
    type: aws:kinesis:FirehoseDeliveryStream
    name: example
    properties:
      name: example-kinesis-delivery-stream
      destination: extended_s3
      extendedS3Configuration:
        bucketArn: ${exampleAwsS3Bucket.arn}
        roleArn: ${exampleAwsIamRole.arn}
  test:
    type: aws:kinesis:AnalyticsApplication
    properties:
      name: example-application
      cloudwatchLoggingOptions:
        logStreamArn: ${exampleLogStream.arn}
        roleArn: ${exampleAwsIamRole.arn}
      inputs:
        namePrefix: example_prefix
        schema:
          recordColumns:
            - name: COLUMN_1
              sqlType: INTEGER
          recordFormat:
            mappingParameters:
              csv:
                recordColumnDelimiter: ','
                recordRowDelimiter: '|'
        kinesisStream:
          resourceArn: ${exampleStream.arn}
          roleArn: ${exampleAwsIamRole.arn}
        startingPositionConfigurations:
          - startingPosition: NOW
      outputs:
        - name: OUTPUT_1
          schema:
            recordFormatType: CSV
          kinesisFirehose:
            resourceArn: ${exampleFirehoseDeliveryStream.arn}
            roleArn: ${exampleAwsIamRole.arn}
      startApplication: true

    Create AnalyticsApplication Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new AnalyticsApplication(name: string, args?: AnalyticsApplicationArgs, opts?: CustomResourceOptions);
    @overload
def AnalyticsApplication(resource_name: str,
                         args: Optional[AnalyticsApplicationArgs] = None,
                         opts: Optional[ResourceOptions] = None)

@overload
def AnalyticsApplication(resource_name: str,
                         opts: Optional[ResourceOptions] = None,
                         cloudwatch_logging_options: Optional[AnalyticsApplicationCloudwatchLoggingOptionsArgs] = None,
                         code: Optional[str] = None,
                         description: Optional[str] = None,
                         inputs: Optional[AnalyticsApplicationInputsArgs] = None,
                         name: Optional[str] = None,
                         outputs: Optional[Sequence[AnalyticsApplicationOutputArgs]] = None,
                         reference_data_sources: Optional[AnalyticsApplicationReferenceDataSourcesArgs] = None,
                         start_application: Optional[bool] = None,
                         tags: Optional[Mapping[str, str]] = None)
    func NewAnalyticsApplication(ctx *Context, name string, args *AnalyticsApplicationArgs, opts ...ResourceOption) (*AnalyticsApplication, error)
    public AnalyticsApplication(string name, AnalyticsApplicationArgs? args = null, CustomResourceOptions? opts = null)
    public AnalyticsApplication(String name, AnalyticsApplicationArgs args)
public AnalyticsApplication(String name, AnalyticsApplicationArgs args, CustomResourceOptions options)

    type: aws:kinesis:AnalyticsApplication
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    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.
    args AnalyticsApplicationArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control 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.
    name String
    The unique name of the resource.
    args AnalyticsApplicationArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var analyticsApplicationResource = new Aws.Kinesis.AnalyticsApplication("analyticsApplicationResource", new()
{
    CloudwatchLoggingOptions = new Aws.Kinesis.Inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs
    {
        LogStreamArn = "string",
        RoleArn = "string",
        Id = "string",
    },
    Code = "string",
    Description = "string",
    Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
    {
        NamePrefix = "string",
        Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
        {
            RecordColumns = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                {
                    Name = "string",
                    SqlType = "string",
                    Mapping = "string",
                },
            },
            RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
            {
                MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                {
                    Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs
                    {
                        RecordColumnDelimiter = "string",
                        RecordRowDelimiter = "string",
                    },
                    Json = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs
                    {
                        RecordRowPath = "string",
                    },
                },
                RecordFormatType = "string",
            },
            RecordEncoding = "string",
        },
        Id = "string",
        KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisFirehoseArgs
        {
            ResourceArn = "string",
            RoleArn = "string",
        },
        KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
        {
            ResourceArn = "string",
            RoleArn = "string",
        },
        Parallelism = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsParallelismArgs
        {
            Count = 0,
        },
        ProcessingConfiguration = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsProcessingConfigurationArgs
        {
            Lambda = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsProcessingConfigurationLambdaArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
        },
        StartingPositionConfigurations = new[]
        {
            new Aws.Kinesis.Inputs.AnalyticsApplicationInputsStartingPositionConfigurationArgs
            {
                StartingPosition = "string",
            },
        },
        StreamNames = new[]
        {
            "string",
        },
    },
    Name = "string",
    Outputs = new[]
    {
        new Aws.Kinesis.Inputs.AnalyticsApplicationOutputArgs
        {
            Name = "string",
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputSchemaArgs
            {
                RecordFormatType = "string",
            },
            Id = "string",
            KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisFirehoseArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisStreamArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
            Lambda = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputLambdaArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
        },
    },
    ReferenceDataSources = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesArgs
    {
        S3 = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesS3Args
        {
            BucketArn = "string",
            FileKey = "string",
            RoleArn = "string",
        },
        Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaArgs
        {
            RecordColumns = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs
                {
                    Name = "string",
                    SqlType = "string",
                    Mapping = "string",
                },
            },
            RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs
            {
                MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs
                {
                    Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs
                    {
                        RecordColumnDelimiter = "string",
                        RecordRowDelimiter = "string",
                    },
                    Json = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs
                    {
                        RecordRowPath = "string",
                    },
                },
                RecordFormatType = "string",
            },
            RecordEncoding = "string",
        },
        TableName = "string",
        Id = "string",
    },
    StartApplication = false,
    Tags = 
    {
        { "string", "string" },
    },
});

    example, err := kinesis.NewAnalyticsApplication(ctx, "analyticsApplicationResource", &kinesis.AnalyticsApplicationArgs{
	CloudwatchLoggingOptions: &kinesis.AnalyticsApplicationCloudwatchLoggingOptionsArgs{
		LogStreamArn: pulumi.String("string"),
		RoleArn:      pulumi.String("string"),
		Id:           pulumi.String("string"),
	},
	Code:        pulumi.String("string"),
	Description: pulumi.String("string"),
	Inputs: &kinesis.AnalyticsApplicationInputsArgs{
		NamePrefix: pulumi.String("string"),
		Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
			RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
				&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
					Name:    pulumi.String("string"),
					SqlType: pulumi.String("string"),
					Mapping: pulumi.String("string"),
				},
			},
			RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
				MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
					Csv: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs{
						RecordColumnDelimiter: pulumi.String("string"),
						RecordRowDelimiter:    pulumi.String("string"),
					},
					Json: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs{
						RecordRowPath: pulumi.String("string"),
					},
				},
				RecordFormatType: pulumi.String("string"),
			},
			RecordEncoding: pulumi.String("string"),
		},
		Id: pulumi.String("string"),
		KinesisFirehose: &kinesis.AnalyticsApplicationInputsKinesisFirehoseArgs{
			ResourceArn: pulumi.String("string"),
			RoleArn:     pulumi.String("string"),
		},
		KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
			ResourceArn: pulumi.String("string"),
			RoleArn:     pulumi.String("string"),
		},
		Parallelism: &kinesis.AnalyticsApplicationInputsParallelismArgs{
			Count: pulumi.Int(0),
		},
		ProcessingConfiguration: &kinesis.AnalyticsApplicationInputsProcessingConfigurationArgs{
			Lambda: &kinesis.AnalyticsApplicationInputsProcessingConfigurationLambdaArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
		},
		StartingPositionConfigurations: kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArray{
			&kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArgs{
				StartingPosition: pulumi.String("string"),
			},
		},
		StreamNames: pulumi.StringArray{
			pulumi.String("string"),
		},
	},
	Name: pulumi.String("string"),
	Outputs: kinesis.AnalyticsApplicationOutputTypeArray{
		&kinesis.AnalyticsApplicationOutputTypeArgs{
			Name: pulumi.String("string"),
			Schema: &kinesis.AnalyticsApplicationOutputSchemaArgs{
				RecordFormatType: pulumi.String("string"),
			},
			Id: pulumi.String("string"),
			KinesisFirehose: &kinesis.AnalyticsApplicationOutputKinesisFirehoseArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
			KinesisStream: &kinesis.AnalyticsApplicationOutputKinesisStreamArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
			Lambda: &kinesis.AnalyticsApplicationOutputLambdaArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
		},
	},
	ReferenceDataSources: &kinesis.AnalyticsApplicationReferenceDataSourcesArgs{
		S3: &kinesis.AnalyticsApplicationReferenceDataSourcesS3Args{
			BucketArn: pulumi.String("string"),
			FileKey:   pulumi.String("string"),
			RoleArn:   pulumi.String("string"),
		},
		Schema: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaArgs{
			RecordColumns: kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArray{
				&kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs{
					Name:    pulumi.String("string"),
					SqlType: pulumi.String("string"),
					Mapping: pulumi.String("string"),
				},
			},
			RecordFormat: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs{
				MappingParameters: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs{
					Csv: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs{
						RecordColumnDelimiter: pulumi.String("string"),
						RecordRowDelimiter:    pulumi.String("string"),
					},
					Json: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs{
						RecordRowPath: pulumi.String("string"),
					},
				},
				RecordFormatType: pulumi.String("string"),
			},
			RecordEncoding: pulumi.String("string"),
		},
		TableName: pulumi.String("string"),
		Id:        pulumi.String("string"),
	},
	StartApplication: pulumi.Bool(false),
	Tags: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
})

    var analyticsApplicationResource = new AnalyticsApplication("analyticsApplicationResource", AnalyticsApplicationArgs.builder()
    .cloudwatchLoggingOptions(AnalyticsApplicationCloudwatchLoggingOptionsArgs.builder()
        .logStreamArn("string")
        .roleArn("string")
        .id("string")
        .build())
    .code("string")
    .description("string")
    .inputs(AnalyticsApplicationInputsArgs.builder()
        .namePrefix("string")
        .schema(AnalyticsApplicationInputsSchemaArgs.builder()
            .recordColumns(AnalyticsApplicationInputsSchemaRecordColumnArgs.builder()
                .name("string")
                .sqlType("string")
                .mapping("string")
                .build())
            .recordFormat(AnalyticsApplicationInputsSchemaRecordFormatArgs.builder()
                .mappingParameters(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs.builder()
                    .csv(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs.builder()
                        .recordColumnDelimiter("string")
                        .recordRowDelimiter("string")
                        .build())
                    .json(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs.builder()
                        .recordRowPath("string")
                        .build())
                    .build())
                .recordFormatType("string")
                .build())
            .recordEncoding("string")
            .build())
        .id("string")
        .kinesisFirehose(AnalyticsApplicationInputsKinesisFirehoseArgs.builder()
            .resourceArn("string")
            .roleArn("string")
            .build())
        .kinesisStream(AnalyticsApplicationInputsKinesisStreamArgs.builder()
            .resourceArn("string")
            .roleArn("string")
            .build())
        .parallelism(AnalyticsApplicationInputsParallelismArgs.builder()
            .count(0)
            .build())
        .processingConfiguration(AnalyticsApplicationInputsProcessingConfigurationArgs.builder()
            .lambda(AnalyticsApplicationInputsProcessingConfigurationLambdaArgs.builder()
                .resourceArn("string")
                .roleArn("string")
                .build())
            .build())
        .startingPositionConfigurations(AnalyticsApplicationInputsStartingPositionConfigurationArgs.builder()
            .startingPosition("string")
            .build())
        .streamNames("string")
        .build())
    .name("string")
    .outputs(AnalyticsApplicationOutputArgs.builder()
        .name("string")
        .schema(AnalyticsApplicationOutputSchemaArgs.builder()
            .recordFormatType("string")
            .build())
        .id("string")
        .kinesisFirehose(AnalyticsApplicationOutputKinesisFirehoseArgs.builder()
            .resourceArn("string")
            .roleArn("string")
            .build())
        .kinesisStream(AnalyticsApplicationOutputKinesisStreamArgs.builder()
            .resourceArn("string")
            .roleArn("string")
            .build())
        .lambda(AnalyticsApplicationOutputLambdaArgs.builder()
            .resourceArn("string")
            .roleArn("string")
            .build())
        .build())
    .referenceDataSources(AnalyticsApplicationReferenceDataSourcesArgs.builder()
        .s3(AnalyticsApplicationReferenceDataSourcesS3Args.builder()
            .bucketArn("string")
            .fileKey("string")
            .roleArn("string")
            .build())
        .schema(AnalyticsApplicationReferenceDataSourcesSchemaArgs.builder()
            .recordColumns(AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs.builder()
                .name("string")
                .sqlType("string")
                .mapping("string")
                .build())
            .recordFormat(AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs.builder()
                .mappingParameters(AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs.builder()
                    .csv(AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs.builder()
                        .recordColumnDelimiter("string")
                        .recordRowDelimiter("string")
                        .build())
                    .json(AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs.builder()
                        .recordRowPath("string")
                        .build())
                    .build())
                .recordFormatType("string")
                .build())
            .recordEncoding("string")
            .build())
        .tableName("string")
        .id("string")
        .build())
    .startApplication(false)
    .tags(Map.of("string", "string"))
    .build());

    analytics_application_resource = aws.kinesis.AnalyticsApplication("analyticsApplicationResource",
    cloudwatch_logging_options={
        "log_stream_arn": "string",
        "role_arn": "string",
        "id": "string",
    },
    code="string",
    description="string",
    inputs={
        "name_prefix": "string",
        "schema": {
            "record_columns": [{
                "name": "string",
                "sql_type": "string",
                "mapping": "string",
            }],
            "record_format": {
                "mapping_parameters": {
                    "csv": {
                        "record_column_delimiter": "string",
                        "record_row_delimiter": "string",
                    },
                    "json": {
                        "record_row_path": "string",
                    },
                },
                "record_format_type": "string",
            },
            "record_encoding": "string",
        },
        "id": "string",
        "kinesis_firehose": {
            "resource_arn": "string",
            "role_arn": "string",
        },
        "kinesis_stream": {
            "resource_arn": "string",
            "role_arn": "string",
        },
        "parallelism": {
            "count": 0,
        },
        "processing_configuration": {
            "lambda_": {
                "resource_arn": "string",
                "role_arn": "string",
            },
        },
        "starting_position_configurations": [{
            "starting_position": "string",
        }],
        "stream_names": ["string"],
    },
    name="string",
    outputs=[{
        "name": "string",
        "schema": {
            "record_format_type": "string",
        },
        "id": "string",
        "kinesis_firehose": {
            "resource_arn": "string",
            "role_arn": "string",
        },
        "kinesis_stream": {
            "resource_arn": "string",
            "role_arn": "string",
        },
        "lambda_": {
            "resource_arn": "string",
            "role_arn": "string",
        },
    }],
    reference_data_sources={
        "s3": {
            "bucket_arn": "string",
            "file_key": "string",
            "role_arn": "string",
        },
        "schema": {
            "record_columns": [{
                "name": "string",
                "sql_type": "string",
                "mapping": "string",
            }],
            "record_format": {
                "mapping_parameters": {
                    "csv": {
                        "record_column_delimiter": "string",
                        "record_row_delimiter": "string",
                    },
                    "json": {
                        "record_row_path": "string",
                    },
                },
                "record_format_type": "string",
            },
            "record_encoding": "string",
        },
        "table_name": "string",
        "id": "string",
    },
    start_application=False,
    tags={
        "string": "string",
    })

    const analyticsApplicationResource = new aws.kinesis.AnalyticsApplication("analyticsApplicationResource", {
    cloudwatchLoggingOptions: {
        logStreamArn: "string",
        roleArn: "string",
        id: "string",
    },
    code: "string",
    description: "string",
    inputs: {
        namePrefix: "string",
        schema: {
            recordColumns: [{
                name: "string",
                sqlType: "string",
                mapping: "string",
            }],
            recordFormat: {
                mappingParameters: {
                    csv: {
                        recordColumnDelimiter: "string",
                        recordRowDelimiter: "string",
                    },
                    json: {
                        recordRowPath: "string",
                    },
                },
                recordFormatType: "string",
            },
            recordEncoding: "string",
        },
        id: "string",
        kinesisFirehose: {
            resourceArn: "string",
            roleArn: "string",
        },
        kinesisStream: {
            resourceArn: "string",
            roleArn: "string",
        },
        parallelism: {
            count: 0,
        },
        processingConfiguration: {
            lambda: {
                resourceArn: "string",
                roleArn: "string",
            },
        },
        startingPositionConfigurations: [{
            startingPosition: "string",
        }],
        streamNames: ["string"],
    },
    name: "string",
    outputs: [{
        name: "string",
        schema: {
            recordFormatType: "string",
        },
        id: "string",
        kinesisFirehose: {
            resourceArn: "string",
            roleArn: "string",
        },
        kinesisStream: {
            resourceArn: "string",
            roleArn: "string",
        },
        lambda: {
            resourceArn: "string",
            roleArn: "string",
        },
    }],
    referenceDataSources: {
        s3: {
            bucketArn: "string",
            fileKey: "string",
            roleArn: "string",
        },
        schema: {
            recordColumns: [{
                name: "string",
                sqlType: "string",
                mapping: "string",
            }],
            recordFormat: {
                mappingParameters: {
                    csv: {
                        recordColumnDelimiter: "string",
                        recordRowDelimiter: "string",
                    },
                    json: {
                        recordRowPath: "string",
                    },
                },
                recordFormatType: "string",
            },
            recordEncoding: "string",
        },
        tableName: "string",
        id: "string",
    },
    startApplication: false,
    tags: {
        string: "string",
    },
});

    type: aws:kinesis:AnalyticsApplication
properties:
    cloudwatchLoggingOptions:
        id: string
        logStreamArn: string
        roleArn: string
    code: string
    description: string
    inputs:
        id: string
        kinesisFirehose:
            resourceArn: string
            roleArn: string
        kinesisStream:
            resourceArn: string
            roleArn: string
        namePrefix: string
        parallelism:
            count: 0
        processingConfiguration:
            lambda:
                resourceArn: string
                roleArn: string
        schema:
            recordColumns:
                - mapping: string
                  name: string
                  sqlType: string
            recordEncoding: string
            recordFormat:
                mappingParameters:
                    csv:
                        recordColumnDelimiter: string
                        recordRowDelimiter: string
                    json:
                        recordRowPath: string
                recordFormatType: string
        startingPositionConfigurations:
            - startingPosition: string
        streamNames:
            - string
    name: string
    outputs:
        - id: string
          kinesisFirehose:
            resourceArn: string
            roleArn: string
          kinesisStream:
            resourceArn: string
            roleArn: string
          lambda:
            resourceArn: string
            roleArn: string
          name: string
          schema:
            recordFormatType: string
    referenceDataSources:
        id: string
        s3:
            bucketArn: string
            fileKey: string
            roleArn: string
        schema:
            recordColumns:
                - mapping: string
                  name: string
                  sqlType: string
            recordEncoding: string
            recordFormat:
                mappingParameters:
                    csv:
                        recordColumnDelimiter: string
                        recordRowDelimiter: string
                    json:
                        recordRowPath: string
                recordFormatType: string
        tableName: string
    startApplication: false
    tags:
        string: string

    AnalyticsApplication Resource Properties

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

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The AnalyticsApplication resource accepts the following input properties:

    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 List<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.
    StartApplication bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    Tags Dictionary<string, string>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    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 []AnalyticsApplicationOutputTypeArgs
    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.
    StartApplication bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    Tags map[string]string
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    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 List<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.
    startApplication Boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    tags Map<String,String>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    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.
    startApplication boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    tags {[key: string]: string}
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    cloudwatch_logging_options AnalyticsApplicationCloudwatchLoggingOptionsArgs
    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 AnalyticsApplicationInputsArgs
    Input configuration of the application. See Inputs below for more details.
    name str
    Name of the Kinesis Analytics Application.
    outputs Sequence[AnalyticsApplicationOutputArgs]
    Output destination configuration of the application. See Outputs below for more details.
    reference_data_sources AnalyticsApplicationReferenceDataSourcesArgs
    An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
    start_application bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    tags Mapping[str, str]
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    cloudwatchLoggingOptions Property Map
    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 Property Map
    Input configuration of the application. See Inputs below for more details.
    name String
    Name of the Kinesis Analytics Application.
    outputs List<Property Map>
    Output destination configuration of the application. See Outputs below for more details.
    referenceDataSources Property Map
    An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
    startApplication Boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    tags Map<String>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.

    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.
    TagsAll Dictionary<string, string>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    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.
    TagsAll map[string]string
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    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.
    tagsAll Map<String,String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version Integer
    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.
    tagsAll {[key: string]: string}
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    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.
    tags_all Mapping[str, str]
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version int
    The Version of the application.
    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.
    tagsAll Map<String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version Number
    The Version of the application.

    Look up 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
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        arn: Optional[str] = None,
        cloudwatch_logging_options: Optional[AnalyticsApplicationCloudwatchLoggingOptionsArgs] = None,
        code: Optional[str] = None,
        create_timestamp: Optional[str] = None,
        description: Optional[str] = None,
        inputs: Optional[AnalyticsApplicationInputsArgs] = None,
        last_update_timestamp: Optional[str] = None,
        name: Optional[str] = None,
        outputs: Optional[Sequence[AnalyticsApplicationOutputArgs]] = None,
        reference_data_sources: Optional[AnalyticsApplicationReferenceDataSourcesArgs] = None,
        start_application: Optional[bool] = None,
        status: Optional[str] = None,
        tags: Optional[Mapping[str, str]] = None,
        tags_all: Optional[Mapping[str, str]] = None,
        version: Optional[int] = None) -> AnalyticsApplication
    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)
    public static AnalyticsApplication get(String name, Output<String> id, AnalyticsApplicationState state, CustomResourceOptions options)
    resources:  _:    type: aws:kinesis:AnalyticsApplication    get:      id: ${id}
    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.
    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 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 List<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.
    StartApplication bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    Status string
    The Status of the application.
    Tags Dictionary<string, string>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    TagsAll Dictionary<string, string>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    Version int
    The Version of the application.
    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 []AnalyticsApplicationOutputTypeArgs
    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.
    StartApplication bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    Status string
    The Status of the application.
    Tags map[string]string
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    TagsAll map[string]string
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    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 List<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.
    startApplication Boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    status String
    The Status of the application.
    tags Map<String,String>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    tagsAll Map<String,String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version Integer
    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.
    startApplication boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    status string
    The Status of the application.
    tags {[key: string]: string}
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    tagsAll {[key: string]: string}
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version number
    The Version of the application.
    arn str
    The ARN of the Kinesis Analytics Appliation.
    cloudwatch_logging_options AnalyticsApplicationCloudwatchLoggingOptionsArgs
    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 AnalyticsApplicationInputsArgs
    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 Sequence[AnalyticsApplicationOutputArgs]
    Output destination configuration of the application. See Outputs below for more details.
    reference_data_sources AnalyticsApplicationReferenceDataSourcesArgs
    An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
    start_application bool
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    status str
    The Status of the application.
    tags Mapping[str, str]
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    tags_all Mapping[str, str]
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version int
    The Version of the application.
    arn
    The ARN of the Kinesis Analytics Appliation.
    cloudwatchLoggingOptions Property Map
    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 Property Map
    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<Property Map>
    Output destination configuration of the application. See Outputs below for more details.
    referenceDataSources Property Map
    An S3 Reference Data Source for the application. See Reference Data Sources below for more details.
    startApplication Boolean
    Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured. To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
    status String
    The Status of the application.
    tags Map<String>
    Key-value map of tags for the Kinesis Analytics Application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.
    tagsAll Map<String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version Number
    The Version of the application.

    Supporting Types

    AnalyticsApplicationCloudwatchLoggingOptions, AnalyticsApplicationCloudwatchLoggingOptionsArgs

    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 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.
    log_stream_arn 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.
    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.

    AnalyticsApplicationInputs, AnalyticsApplicationInputsArgs

    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 List<AnalyticsApplicationInputsStartingPositionConfiguration>
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    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
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    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 List<AnalyticsApplicationInputsStartingPositionConfiguration>
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    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[]
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    streamNames string[]
    name_prefix str
    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 str
    The ARN of the Kinesis Analytics Application.
    kinesis_firehose AnalyticsApplicationInputsKinesisFirehose
    The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
    kinesis_stream 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.
    processing_configuration AnalyticsApplicationInputsProcessingConfiguration
    The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
    starting_position_configurations Sequence[AnalyticsApplicationInputsStartingPositionConfiguration]
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    stream_names Sequence[str]
    namePrefix String
    The Name Prefix to use when creating an in-application stream.
    schema Property Map
    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 Property Map
    The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
    kinesisStream Property Map
    The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
    parallelism Property Map
    The number of Parallel in-application streams to create. See Parallelism below for more details.
    processingConfiguration Property Map
    The Processing Configuration to transform records as they are received from the stream. See Processing Configuration below for more details.
    startingPositionConfigurations List<Property Map>
    The point at which the application starts processing records from the streaming source. See Starting Position Configuration below for more details.
    streamNames List<String>

    AnalyticsApplicationInputsKinesisFirehose, AnalyticsApplicationInputsKinesisFirehoseArgs

    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.
    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.
    resourceArn String
    The ARN of the Kinesis Firehose delivery stream.
    roleArn String
    The ARN of the IAM Role used to access the stream.

    AnalyticsApplicationInputsKinesisStream, AnalyticsApplicationInputsKinesisStreamArgs

    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.
    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.
    resourceArn String
    The ARN of the Kinesis Stream.
    roleArn String
    The ARN of the IAM Role used to access the stream.

    AnalyticsApplicationInputsParallelism, AnalyticsApplicationInputsParallelismArgs

    Count int
    The Count of streams.
    Count int
    The Count of streams.
    count Integer
    The Count of streams.
    count number
    The Count of streams.
    count int
    The Count of streams.
    count Number
    The Count of streams.

    AnalyticsApplicationInputsProcessingConfiguration, AnalyticsApplicationInputsProcessingConfigurationArgs

    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 AnalyticsApplicationInputsProcessingConfigurationLambda
    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 Property Map
    The Lambda function configuration. See Lambda below for more details.

    AnalyticsApplicationInputsProcessingConfigurationLambda, AnalyticsApplicationInputsProcessingConfigurationLambdaArgs

    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.
    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.
    resourceArn String
    The ARN of the Lambda function.
    roleArn String
    The ARN of the IAM Role used to access the Lambda function.

    AnalyticsApplicationInputsSchema, AnalyticsApplicationInputsSchemaArgs

    RecordColumns List<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 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.
    record_columns Sequence[AnalyticsApplicationInputsSchemaRecordColumn]
    The Record Column mapping for the streaming source data element. See Record Columns below for more details.
    record_format AnalyticsApplicationInputsSchemaRecordFormat
    The Record Format and mapping information to schematize a record. See Record Format below for more details.
    record_encoding str
    The Encoding of the record in the streaming source.
    recordColumns List<Property Map>
    The Record Column mapping for the streaming source data element. See Record Columns below for more details.
    recordFormat Property Map
    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.

    AnalyticsApplicationInputsSchemaRecordColumn, AnalyticsApplicationInputsSchemaRecordColumnArgs

    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 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.
    sql_type str
    The SQL Type of the column.
    mapping str
    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.

    AnalyticsApplicationInputsSchemaRecordFormat, AnalyticsApplicationInputsSchemaRecordFormatArgs

    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 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.
    mapping_parameters AnalyticsApplicationInputsSchemaRecordFormatMappingParameters
    The Mapping Information for the record format. See Mapping Parameters below for more details.
    record_format_type str
    The type of Record Format. Can be CSV or JSON.
    mappingParameters Property Map
    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.

    AnalyticsApplicationInputsSchemaRecordFormatMappingParameters, AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs

    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 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 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 Property Map
    Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
    json Property Map
    Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

    AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsv, AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs

    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 string
    The Column Delimiter.
    recordRowDelimiter string
    The Row Delimiter.
    record_column_delimiter str
    The Column Delimiter.
    record_row_delimiter str
    The Row Delimiter.
    recordColumnDelimiter String
    The Column Delimiter.
    recordRowDelimiter String
    The Row Delimiter.

    AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJson, AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs

    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 string
    Path to the top-level parent that contains the records.
    record_row_path str
    Path to the top-level parent that contains the records.
    recordRowPath String
    Path to the top-level parent that contains the records.

    AnalyticsApplicationInputsStartingPositionConfiguration, AnalyticsApplicationInputsStartingPositionConfigurationArgs

    StartingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    StartingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    startingPosition String
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    startingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    starting_position str
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    startingPosition String
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.

    AnalyticsApplicationOutput, AnalyticsApplicationOutputArgs

    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 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 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.
    kinesis_firehose AnalyticsApplicationOutputKinesisFirehose
    The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
    kinesis_stream 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 Property Map
    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 Property Map
    The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream. See Kinesis Firehose below for more details.
    kinesisStream Property Map
    The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose. See Kinesis Stream below for more details.
    lambda Property Map
    The Lambda function destination. See Lambda below for more details.

    AnalyticsApplicationOutputKinesisFirehose, AnalyticsApplicationOutputKinesisFirehoseArgs

    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.
    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.
    resourceArn String
    The ARN of the Kinesis Firehose delivery stream.
    roleArn String
    The ARN of the IAM Role used to access the stream.

    AnalyticsApplicationOutputKinesisStream, AnalyticsApplicationOutputKinesisStreamArgs

    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.
    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.
    resourceArn String
    The ARN of the Kinesis Stream.
    roleArn String
    The ARN of the IAM Role used to access the stream.

    AnalyticsApplicationOutputLambda, AnalyticsApplicationOutputLambdaArgs

    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.
    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.
    resourceArn String
    The ARN of the Lambda function.
    roleArn String
    The ARN of the IAM Role used to access the Lambda function.

    AnalyticsApplicationOutputSchema, AnalyticsApplicationOutputSchemaArgs

    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 string
    The Format Type of the records on the output stream. Can be CSV or JSON.
    record_format_type str
    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.

    AnalyticsApplicationReferenceDataSources, AnalyticsApplicationReferenceDataSourcesArgs

    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 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 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.
    table_name str
    The in-application Table Name.
    id str
    The ARN of the Kinesis Analytics Application.
    s3 Property Map
    The S3 configuration for the reference data source. See S3 Reference below for more details.
    schema Property Map
    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.

    AnalyticsApplicationReferenceDataSourcesS3, AnalyticsApplicationReferenceDataSourcesS3Args

    BucketArn string
    The S3 Bucket ARN.
    FileKey string
    The File Key name containing reference data.
    RoleArn string
    The IAM Role ARN to read the data.
    BucketArn string
    The S3 Bucket ARN.
    FileKey string
    The File Key name containing reference data.
    RoleArn string
    The IAM Role ARN to read the data.
    bucketArn String
    The S3 Bucket ARN.
    fileKey String
    The File Key name containing reference data.
    roleArn String
    The IAM Role ARN to read the data.
    bucketArn string
    The S3 Bucket ARN.
    fileKey string
    The File Key name containing reference data.
    roleArn string
    The IAM Role ARN to read the data.
    bucket_arn str
    The S3 Bucket ARN.
    file_key str
    The File Key name containing reference data.
    role_arn str
    The IAM Role ARN to read the data.
    bucketArn String
    The S3 Bucket ARN.
    fileKey String
    The File Key name containing reference data.
    roleArn String
    The IAM Role ARN to read the data.

    AnalyticsApplicationReferenceDataSourcesSchema, AnalyticsApplicationReferenceDataSourcesSchemaArgs

    RecordColumns List<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 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.
    record_columns Sequence[AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn]
    The Record Column mapping for the streaming source data element. See Record Columns below for more details.
    record_format AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat
    The Record Format and mapping information to schematize a record. See Record Format below for more details.
    record_encoding str
    The Encoding of the record in the streaming source.
    recordColumns List<Property Map>
    The Record Column mapping for the streaming source data element. See Record Columns below for more details.
    recordFormat Property Map
    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.

    AnalyticsApplicationReferenceDataSourcesSchemaRecordColumn, AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs

    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 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.
    sql_type str
    The SQL Type of the column.
    mapping str
    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.

    AnalyticsApplicationReferenceDataSourcesSchemaRecordFormat, AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs

    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 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.
    mapping_parameters AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters
    The Mapping Information for the record format. See Mapping Parameters below for more details.
    record_format_type str
    The type of Record Format. Can be CSV or JSON.
    mappingParameters Property Map
    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.

    AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParameters, AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs

    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 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 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 Property Map
    Mapping information when the record format uses delimiters. See CSV Mapping Parameters below for more details.
    json Property Map
    Mapping information when JSON is the record format on the streaming source. See JSON Mapping Parameters below for more details.

    AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsv, AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs

    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 string
    The Column Delimiter.
    recordRowDelimiter string
    The Row Delimiter.
    record_column_delimiter str
    The Column Delimiter.
    record_row_delimiter str
    The Row Delimiter.
    recordColumnDelimiter String
    The Column Delimiter.
    recordRowDelimiter String
    The Row Delimiter.

    AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJson, AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs

    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 string
    Path to the top-level parent that contains the records.
    record_row_path str
    Path to the top-level parent that contains the records.
    recordRowPath String
    Path to the top-level parent that contains the records.

    Import

    Using pulumi import, import Kinesis Analytics Application using ARN. For example:

    $ pulumi import aws:kinesis/analyticsApplication:AnalyticsApplication example arn:aws:kinesisanalytics:us-west-2:1234567890:application/example

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    AWS Classic pulumi/pulumi-aws
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the aws Terraform Provider.
    aws logo
    AWS v6.73.0 published on Wednesday, Mar 19, 2025 by Pulumi
    pulumi/pulumi-aws