Class AnalyticsApplication

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

For more details, see the Amazon Kinesis Analytics Documentation.

Example Usage

using Pulumi;
using Aws = Pulumi.Aws;

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

}

Inheritance

System.Object

Resource

CustomResource

AnalyticsApplication

Inherited Members

CustomResource.Id

Resource.GetResourceType()

Resource.GetResourceName()

Resource.Urn

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Pulumi.Aws.Kinesis

Assembly: Pulumi.Aws.dll

Syntax

public class AnalyticsApplication : CustomResource

Constructors

AnalyticsApplication(String, AnalyticsApplicationArgs, CustomResourceOptions)

Create a AnalyticsApplication resource with the given unique name, arguments, and options.

Declaration

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

Parameters

Type	Name	Description
System.String	name	The unique name of the resource
AnalyticsApplicationArgs	args	The arguments used to populate this resource's properties
CustomResourceOptions	options	A bag of options that control this resource's behavior

Properties

Arn

The ARN of the Kinesis Analytics Appliation.

Declaration

public Output<string> Arn { get; }

Property Value

Type	Description
Output<System.String>

CloudwatchLoggingOptions

The CloudWatch log stream options to monitor application errors. See CloudWatch Logging Options below for more details.

Declaration

public Output<AnalyticsApplicationCloudwatchLoggingOptions> CloudwatchLoggingOptions { get; }

Property Value

Type	Description
Output<AnalyticsApplicationCloudwatchLoggingOptions>

Code

SQL Code to transform input data, and generate output.

Declaration

public Output<string> Code { get; }

Property Value

Type	Description
Output<System.String>

CreateTimestamp

The Timestamp when the application version was created.

Declaration

public Output<string> CreateTimestamp { get; }

Property Value

Type	Description
Output<System.String>

Description

Description of the application.

Declaration

public Output<string> Description { get; }

Property Value

Type	Description
Output<System.String>

Inputs

Input configuration of the application. See Inputs below for more details.

Declaration

public Output<AnalyticsApplicationInputs> Inputs { get; }

Property Value

Type	Description
Output<AnalyticsApplicationInputs>

LastUpdateTimestamp

The Timestamp when the application was last updated.

Declaration

public Output<string> LastUpdateTimestamp { get; }

Property Value

Type	Description
Output<System.String>

Name

Name of the Kinesis Analytics Application.

Declaration

public Output<string> Name { get; }

Property Value

Type	Description
Output<System.String>

Outputs

Output destination configuration of the application. See Outputs below for more details.

Declaration

public Output<ImmutableArray<AnalyticsApplicationOutput>> Outputs { get; }

Property Value

Type	Description
Output<System.Collections.Immutable.ImmutableArray<AnalyticsApplicationOutput>>

ReferenceDataSources

An S3 Reference Data Source for the application. See Reference Data Sources below for more details.

Declaration

public Output<AnalyticsApplicationReferenceDataSources> ReferenceDataSources { get; }

Property Value

Type	Description
Output<AnalyticsApplicationReferenceDataSources>

Status

The Status of the application.

Declaration

public Output<string> Status { get; }

Property Value

Type	Description
Output<System.String>

Tags

Key-value map of tags for the Kinesis Analytics Application.

Declaration

public Output<ImmutableDictionary<string, object>> Tags { get; }

Property Value

Type	Description
Output<System.Collections.Immutable.ImmutableDictionary<System.String, System.Object>>

Version

The Version of the application.

Declaration

public Output<int> Version { get; }

Property Value

Type	Description
Output<System.Int32>

Methods

Get(String, Input<String>, AnalyticsApplicationState, CustomResourceOptions)

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

Declaration

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

Parameters

Type	Name	Description
System.String	name	The unique name of the resulting resource.
Input<System.String>	id	The unique provider ID of the resource to lookup.
AnalyticsApplicationState	state	Any extra arguments used during the lookup.
CustomResourceOptions	options	A bag of options that control this resource's behavior

Returns

Type	Description
AnalyticsApplication