AWS Native v0.103.0, Apr 22 24

AWS Native is in preview. AWS Classic is fully supported.

AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi

pulumi/pulumi-aws-native

aws-native.iotanalytics.Pipeline

Explore with Pulumi AI

AWS Native is in preview. AWS Classic is fully supported.

AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi

pulumi/pulumi-aws-native

Example Usage

Example

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

return await Deployment.RunAsync(() => 
{
    var pipeline = new AwsNative.IoTAnalytics.Pipeline("pipeline", new()
    {
        PipelineName = "SimplePipeline",
        PipelineActivities = new[]
        {
            new AwsNative.IoTAnalytics.Inputs.PipelineActivityArgs
            {
                Channel = new AwsNative.IoTAnalytics.Inputs.PipelineChannelArgs
                {
                    Name = "ChannelActivity",
                    ChannelName = "SimpleChannel",
                    Next = "DatastoreActivity",
                },
                Datastore = new AwsNative.IoTAnalytics.Inputs.PipelineDatastoreArgs
                {
                    Name = "DatastoreActivity",
                    DatastoreName = "SimpleDatastore",
                },
            },
        },
    });

});

package main

import (
	"github.com/pulumi/pulumi-aws-native/sdk/go/aws/iotanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := iotanalytics.NewPipeline(ctx, "pipeline", &iotanalytics.PipelineArgs{
			PipelineName: pulumi.String("SimplePipeline"),
			PipelineActivities: iotanalytics.PipelineActivityArray{
				&iotanalytics.PipelineActivityArgs{
					Channel: &iotanalytics.PipelineChannelArgs{
						Name:        pulumi.String("ChannelActivity"),
						ChannelName: pulumi.String("SimpleChannel"),
						Next:        pulumi.String("DatastoreActivity"),
					},
					Datastore: &iotanalytics.PipelineDatastoreArgs{
						Name:          pulumi.String("DatastoreActivity"),
						DatastoreName: pulumi.String("SimpleDatastore"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

Coming soon!

import pulumi
import pulumi_aws_native as aws_native

pipeline = aws_native.iotanalytics.Pipeline("pipeline",
    pipeline_name="SimplePipeline",
    pipeline_activities=[aws_native.iotanalytics.PipelineActivityArgs(
        channel=aws_native.iotanalytics.PipelineChannelArgs(
            name="ChannelActivity",
            channel_name="SimpleChannel",
            next="DatastoreActivity",
        ),
        datastore=aws_native.iotanalytics.PipelineDatastoreArgs(
            name="DatastoreActivity",
            datastore_name="SimpleDatastore",
        ),
    )])

import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";

const pipeline = new aws_native.iotanalytics.Pipeline("pipeline", {
    pipelineName: "SimplePipeline",
    pipelineActivities: [{
        channel: {
            name: "ChannelActivity",
            channelName: "SimpleChannel",
            next: "DatastoreActivity",
        },
        datastore: {
            name: "DatastoreActivity",
            datastoreName: "SimpleDatastore",
        },
    }],
});

Coming soon!

Example

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

return await Deployment.RunAsync(() => 
{
    var pipeline = new AwsNative.IoTAnalytics.Pipeline("pipeline", new()
    {
        PipelineName = "SimplePipeline",
        PipelineActivities = new[]
        {
            new AwsNative.IoTAnalytics.Inputs.PipelineActivityArgs
            {
                Channel = new AwsNative.IoTAnalytics.Inputs.PipelineChannelArgs
                {
                    Name = "ChannelActivity",
                    ChannelName = "SimpleChannel",
                    Next = "DatastoreActivity",
                },
                Datastore = new AwsNative.IoTAnalytics.Inputs.PipelineDatastoreArgs
                {
                    Name = "DatastoreActivity",
                    DatastoreName = "SimpleDatastore",
                },
            },
        },
    });

});

package main

import (
	"github.com/pulumi/pulumi-aws-native/sdk/go/aws/iotanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := iotanalytics.NewPipeline(ctx, "pipeline", &iotanalytics.PipelineArgs{
			PipelineName: pulumi.String("SimplePipeline"),
			PipelineActivities: iotanalytics.PipelineActivityArray{
				&iotanalytics.PipelineActivityArgs{
					Channel: &iotanalytics.PipelineChannelArgs{
						Name:        pulumi.String("ChannelActivity"),
						ChannelName: pulumi.String("SimpleChannel"),
						Next:        pulumi.String("DatastoreActivity"),
					},
					Datastore: &iotanalytics.PipelineDatastoreArgs{
						Name:          pulumi.String("DatastoreActivity"),
						DatastoreName: pulumi.String("SimpleDatastore"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

Coming soon!

import pulumi
import pulumi_aws_native as aws_native

pipeline = aws_native.iotanalytics.Pipeline("pipeline",
    pipeline_name="SimplePipeline",
    pipeline_activities=[aws_native.iotanalytics.PipelineActivityArgs(
        channel=aws_native.iotanalytics.PipelineChannelArgs(
            name="ChannelActivity",
            channel_name="SimpleChannel",
            next="DatastoreActivity",
        ),
        datastore=aws_native.iotanalytics.PipelineDatastoreArgs(
            name="DatastoreActivity",
            datastore_name="SimpleDatastore",
        ),
    )])

import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";

const pipeline = new aws_native.iotanalytics.Pipeline("pipeline", {
    pipelineName: "SimplePipeline",
    pipelineActivities: [{
        channel: {
            name: "ChannelActivity",
            channelName: "SimpleChannel",
            next: "DatastoreActivity",
        },
        datastore: {
            name: "DatastoreActivity",
            datastoreName: "SimpleDatastore",
        },
    }],
});

Coming soon!

Example

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

return await Deployment.RunAsync(() => 
{
    var pipeline = new AwsNative.IoTAnalytics.Pipeline("pipeline", new()
    {
        PipelineName = "ComplexPipeline",
        PipelineActivities = new[]
        {
            new AwsNative.IoTAnalytics.Inputs.PipelineActivityArgs
            {
                Channel = new AwsNative.IoTAnalytics.Inputs.PipelineChannelArgs
                {
                    Name = "ChannelActivity",
                    ChannelName = "Channel",
                    Next = "LambdaActivity",
                },
                Lambda = new AwsNative.IoTAnalytics.Inputs.PipelineLambdaArgs
                {
                    Name = "LambdaActivity",
                    LambdaName = "Lambda",
                    BatchSize = 1,
                    Next = "AddAttributesActivity",
                },
                AddAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineAddAttributesArgs
                {
                    Name = "AddAttributesActivity",
                    Attributes = 
                    {
                        { "key1", "attribute1" },
                        { "key2", "attribute2" },
                    },
                    Next = "RemoveAttributesActivity",
                },
                RemoveAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineRemoveAttributesArgs
                {
                    Name = "RemoveAttributesActivity",
                    Attributes = new[]
                    {
                        "attribute1",
                        "attribute2",
                    },
                    Next = "SelectAttributesActivity",
                },
                SelectAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineSelectAttributesArgs
                {
                    Name = "SelectAttributesActivity",
                    Attributes = new[]
                    {
                        "attribute1",
                        "attribute2",
                    },
                    Next = "FilterActivity",
                },
                Filter = new AwsNative.IoTAnalytics.Inputs.PipelineFilterArgs
                {
                    Name = "FilterActivity",
                    Filter = "attribute1 > 40 AND attribute2 < 20",
                    Next = "MathActivity",
                },
                Math = new AwsNative.IoTAnalytics.Inputs.PipelineMathArgs
                {
                    Name = "MathActivity",
                    Attribute = "attribute",
                    Math = "attribute - 10",
                    Next = "DeviceRegistryEnrichActivity",
                },
                DeviceRegistryEnrich = new AwsNative.IoTAnalytics.Inputs.PipelineDeviceRegistryEnrichArgs
                {
                    Name = "DeviceRegistryEnrichActivity",
                    Attribute = "attribute",
                    ThingName = "thingName",
                    RoleArn = "arn:aws:iam::<your_Account_Id>:role/Enrich",
                    Next = "DeviceShadowEnrichActivity",
                },
                DeviceShadowEnrich = new AwsNative.IoTAnalytics.Inputs.PipelineDeviceShadowEnrichArgs
                {
                    Name = "DeviceShadowEnrichActivity",
                    Attribute = "attribute",
                    ThingName = "thingName",
                    RoleArn = "arn:aws:iam::<your_Account_Id>:role/Enrich",
                    Next = "DatastoreActivity",
                },
                Datastore = new AwsNative.IoTAnalytics.Inputs.PipelineDatastoreArgs
                {
                    Name = "DatastoreActivity",
                    DatastoreName = "Datastore",
                },
            },
        },
    });

});

package main

import (
	"github.com/pulumi/pulumi-aws-native/sdk/go/aws/iotanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := iotanalytics.NewPipeline(ctx, "pipeline", &iotanalytics.PipelineArgs{
			PipelineName: pulumi.String("ComplexPipeline"),
			PipelineActivities: iotanalytics.PipelineActivityArray{
				&iotanalytics.PipelineActivityArgs{
					Channel: &iotanalytics.PipelineChannelArgs{
						Name:        pulumi.String("ChannelActivity"),
						ChannelName: pulumi.String("Channel"),
						Next:        pulumi.String("LambdaActivity"),
					},
					Lambda: &iotanalytics.PipelineLambdaArgs{
						Name:       pulumi.String("LambdaActivity"),
						LambdaName: pulumi.String("Lambda"),
						BatchSize:  pulumi.Int(1),
						Next:       pulumi.String("AddAttributesActivity"),
					},
					AddAttributes: &iotanalytics.PipelineAddAttributesArgs{
						Name: pulumi.String("AddAttributesActivity"),
						Attributes: pulumi.StringMap{
							"key1": pulumi.String("attribute1"),
							"key2": pulumi.String("attribute2"),
						},
						Next: pulumi.String("RemoveAttributesActivity"),
					},
					RemoveAttributes: &iotanalytics.PipelineRemoveAttributesArgs{
						Name: pulumi.String("RemoveAttributesActivity"),
						Attributes: pulumi.StringArray{
							pulumi.String("attribute1"),
							pulumi.String("attribute2"),
						},
						Next: pulumi.String("SelectAttributesActivity"),
					},
					SelectAttributes: &iotanalytics.PipelineSelectAttributesArgs{
						Name: pulumi.String("SelectAttributesActivity"),
						Attributes: pulumi.StringArray{
							pulumi.String("attribute1"),
							pulumi.String("attribute2"),
						},
						Next: pulumi.String("FilterActivity"),
					},
					Filter: &iotanalytics.PipelineFilterArgs{
						Name:   pulumi.String("FilterActivity"),
						Filter: pulumi.String("attribute1 > 40 AND attribute2 < 20"),
						Next:   pulumi.String("MathActivity"),
					},
					Math: &iotanalytics.PipelineMathArgs{
						Name:      pulumi.String("MathActivity"),
						Attribute: pulumi.String("attribute"),
						Math:      pulumi.String("attribute - 10"),
						Next:      pulumi.String("DeviceRegistryEnrichActivity"),
					},
					DeviceRegistryEnrich: &iotanalytics.PipelineDeviceRegistryEnrichArgs{
						Name:      pulumi.String("DeviceRegistryEnrichActivity"),
						Attribute: pulumi.String("attribute"),
						ThingName: pulumi.String("thingName"),
						RoleArn:   pulumi.String("arn:aws:iam::<your_Account_Id>:role/Enrich"),
						Next:      pulumi.String("DeviceShadowEnrichActivity"),
					},
					DeviceShadowEnrich: &iotanalytics.PipelineDeviceShadowEnrichArgs{
						Name:      pulumi.String("DeviceShadowEnrichActivity"),
						Attribute: pulumi.String("attribute"),
						ThingName: pulumi.String("thingName"),
						RoleArn:   pulumi.String("arn:aws:iam::<your_Account_Id>:role/Enrich"),
						Next:      pulumi.String("DatastoreActivity"),
					},
					Datastore: &iotanalytics.PipelineDatastoreArgs{
						Name:          pulumi.String("DatastoreActivity"),
						DatastoreName: pulumi.String("Datastore"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

Coming soon!

import pulumi
import pulumi_aws_native as aws_native

pipeline = aws_native.iotanalytics.Pipeline("pipeline",
    pipeline_name="ComplexPipeline",
    pipeline_activities=[aws_native.iotanalytics.PipelineActivityArgs(
        channel=aws_native.iotanalytics.PipelineChannelArgs(
            name="ChannelActivity",
            channel_name="Channel",
            next="LambdaActivity",
        ),
        lambda_=aws_native.iotanalytics.PipelineLambdaArgs(
            name="LambdaActivity",
            lambda_name="Lambda",
            batch_size=1,
            next="AddAttributesActivity",
        ),
        add_attributes=aws_native.iotanalytics.PipelineAddAttributesArgs(
            name="AddAttributesActivity",
            attributes={
                "key1": "attribute1",
                "key2": "attribute2",
            },
            next="RemoveAttributesActivity",
        ),
        remove_attributes=aws_native.iotanalytics.PipelineRemoveAttributesArgs(
            name="RemoveAttributesActivity",
            attributes=[
                "attribute1",
                "attribute2",
            ],
            next="SelectAttributesActivity",
        ),
        select_attributes=aws_native.iotanalytics.PipelineSelectAttributesArgs(
            name="SelectAttributesActivity",
            attributes=[
                "attribute1",
                "attribute2",
            ],
            next="FilterActivity",
        ),
        filter=aws_native.iotanalytics.PipelineFilterArgs(
            name="FilterActivity",
            filter="attribute1 > 40 AND attribute2 < 20",
            next="MathActivity",
        ),
        math=aws_native.iotanalytics.PipelineMathArgs(
            name="MathActivity",
            attribute="attribute",
            math="attribute - 10",
            next="DeviceRegistryEnrichActivity",
        ),
        device_registry_enrich=aws_native.iotanalytics.PipelineDeviceRegistryEnrichArgs(
            name="DeviceRegistryEnrichActivity",
            attribute="attribute",
            thing_name="thingName",
            role_arn="arn:aws:iam::<your_Account_Id>:role/Enrich",
            next="DeviceShadowEnrichActivity",
        ),
        device_shadow_enrich=aws_native.iotanalytics.PipelineDeviceShadowEnrichArgs(
            name="DeviceShadowEnrichActivity",
            attribute="attribute",
            thing_name="thingName",
            role_arn="arn:aws:iam::<your_Account_Id>:role/Enrich",
            next="DatastoreActivity",
        ),
        datastore=aws_native.iotanalytics.PipelineDatastoreArgs(
            name="DatastoreActivity",
            datastore_name="Datastore",
        ),
    )])

import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";

const pipeline = new aws_native.iotanalytics.Pipeline("pipeline", {
    pipelineName: "ComplexPipeline",
    pipelineActivities: [{
        channel: {
            name: "ChannelActivity",
            channelName: "Channel",
            next: "LambdaActivity",
        },
        lambda: {
            name: "LambdaActivity",
            lambdaName: "Lambda",
            batchSize: 1,
            next: "AddAttributesActivity",
        },
        addAttributes: {
            name: "AddAttributesActivity",
            attributes: {
                key1: "attribute1",
                key2: "attribute2",
            },
            next: "RemoveAttributesActivity",
        },
        removeAttributes: {
            name: "RemoveAttributesActivity",
            attributes: [
                "attribute1",
                "attribute2",
            ],
            next: "SelectAttributesActivity",
        },
        selectAttributes: {
            name: "SelectAttributesActivity",
            attributes: [
                "attribute1",
                "attribute2",
            ],
            next: "FilterActivity",
        },
        filter: {
            name: "FilterActivity",
            filter: "attribute1 > 40 AND attribute2 < 20",
            next: "MathActivity",
        },
        math: {
            name: "MathActivity",
            attribute: "attribute",
            math: "attribute - 10",
            next: "DeviceRegistryEnrichActivity",
        },
        deviceRegistryEnrich: {
            name: "DeviceRegistryEnrichActivity",
            attribute: "attribute",
            thingName: "thingName",
            roleArn: "arn:aws:iam::<your_Account_Id>:role/Enrich",
            next: "DeviceShadowEnrichActivity",
        },
        deviceShadowEnrich: {
            name: "DeviceShadowEnrichActivity",
            attribute: "attribute",
            thingName: "thingName",
            roleArn: "arn:aws:iam::<your_Account_Id>:role/Enrich",
            next: "DatastoreActivity",
        },
        datastore: {
            name: "DatastoreActivity",
            datastoreName: "Datastore",
        },
    }],
});

Coming soon!

Example

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

return await Deployment.RunAsync(() => 
{
    var pipeline = new AwsNative.IoTAnalytics.Pipeline("pipeline", new()
    {
        PipelineName = "ComplexPipeline",
        PipelineActivities = new[]
        {
            new AwsNative.IoTAnalytics.Inputs.PipelineActivityArgs
            {
                Channel = new AwsNative.IoTAnalytics.Inputs.PipelineChannelArgs
                {
                    Name = "ChannelActivity",
                    ChannelName = "Channel",
                    Next = "LambdaActivity",
                },
                Lambda = new AwsNative.IoTAnalytics.Inputs.PipelineLambdaArgs
                {
                    Name = "LambdaActivity",
                    LambdaName = "Lambda",
                    BatchSize = 1,
                    Next = "AddAttributesActivity",
                },
                AddAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineAddAttributesArgs
                {
                    Name = "AddAttributesActivity",
                    Attributes = 
                    {
                        { "key1", "attribute1" },
                        { "key2", "attribute2" },
                    },
                    Next = "RemoveAttributesActivity",
                },
                RemoveAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineRemoveAttributesArgs
                {
                    Name = "RemoveAttributesActivity",
                    Attributes = new[]
                    {
                        "attribute1",
                        "attribute2",
                    },
                    Next = "SelectAttributesActivity",
                },
                SelectAttributes = new AwsNative.IoTAnalytics.Inputs.PipelineSelectAttributesArgs
                {
                    Name = "SelectAttributesActivity",
                    Attributes = new[]
                    {
                        "attribute1",
                        "attribute2",
                    },
                    Next = "FilterActivity",
                },
                Filter = new AwsNative.IoTAnalytics.Inputs.PipelineFilterArgs
                {
                    Name = "FilterActivity",
                    Filter = "attribute1 > 40 AND attribute2 < 20",
                    Next = "MathActivity",
                },
                Math = new AwsNative.IoTAnalytics.Inputs.PipelineMathArgs
                {
                    Name = "MathActivity",
                    Attribute = "attribute",
                    Math = "attribute - 10",
                    Next = "DeviceRegistryEnrichActivity",
                },
                DeviceRegistryEnrich = new AwsNative.IoTAnalytics.Inputs.PipelineDeviceRegistryEnrichArgs
                {
                    Name = "DeviceRegistryEnrichActivity",
                    Attribute = "attribute",
                    ThingName = "thingName",
                    RoleArn = "arn:aws:iam::<your_Account_Id>:role/Enrich",
                    Next = "DeviceShadowEnrichActivity",
                },
                DeviceShadowEnrich = new AwsNative.IoTAnalytics.Inputs.PipelineDeviceShadowEnrichArgs
                {
                    Name = "DeviceShadowEnrichActivity",
                    Attribute = "attribute",
                    ThingName = "thingName",
                    RoleArn = "arn:aws:iam::<your_Account_Id>:role/Enrich",
                    Next = "DatastoreActivity",
                },
                Datastore = new AwsNative.IoTAnalytics.Inputs.PipelineDatastoreArgs
                {
                    Name = "DatastoreActivity",
                    DatastoreName = "Datastore",
                },
            },
        },
    });

});

package main

import (
	"github.com/pulumi/pulumi-aws-native/sdk/go/aws/iotanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := iotanalytics.NewPipeline(ctx, "pipeline", &iotanalytics.PipelineArgs{
			PipelineName: pulumi.String("ComplexPipeline"),
			PipelineActivities: iotanalytics.PipelineActivityArray{
				&iotanalytics.PipelineActivityArgs{
					Channel: &iotanalytics.PipelineChannelArgs{
						Name:        pulumi.String("ChannelActivity"),
						ChannelName: pulumi.String("Channel"),
						Next:        pulumi.String("LambdaActivity"),
					},
					Lambda: &iotanalytics.PipelineLambdaArgs{
						Name:       pulumi.String("LambdaActivity"),
						LambdaName: pulumi.String("Lambda"),
						BatchSize:  pulumi.Int(1),
						Next:       pulumi.String("AddAttributesActivity"),
					},
					AddAttributes: &iotanalytics.PipelineAddAttributesArgs{
						Name: pulumi.String("AddAttributesActivity"),
						Attributes: pulumi.StringMap{
							"key1": pulumi.String("attribute1"),
							"key2": pulumi.String("attribute2"),
						},
						Next: pulumi.String("RemoveAttributesActivity"),
					},
					RemoveAttributes: &iotanalytics.PipelineRemoveAttributesArgs{
						Name: pulumi.String("RemoveAttributesActivity"),
						Attributes: pulumi.StringArray{
							pulumi.String("attribute1"),
							pulumi.String("attribute2"),
						},
						Next: pulumi.String("SelectAttributesActivity"),
					},
					SelectAttributes: &iotanalytics.PipelineSelectAttributesArgs{
						Name: pulumi.String("SelectAttributesActivity"),
						Attributes: pulumi.StringArray{
							pulumi.String("attribute1"),
							pulumi.String("attribute2"),
						},
						Next: pulumi.String("FilterActivity"),
					},
					Filter: &iotanalytics.PipelineFilterArgs{
						Name:   pulumi.String("FilterActivity"),
						Filter: pulumi.String("attribute1 > 40 AND attribute2 < 20"),
						Next:   pulumi.String("MathActivity"),
					},
					Math: &iotanalytics.PipelineMathArgs{
						Name:      pulumi.String("MathActivity"),
						Attribute: pulumi.String("attribute"),
						Math:      pulumi.String("attribute - 10"),
						Next:      pulumi.String("DeviceRegistryEnrichActivity"),
					},
					DeviceRegistryEnrich: &iotanalytics.PipelineDeviceRegistryEnrichArgs{
						Name:      pulumi.String("DeviceRegistryEnrichActivity"),
						Attribute: pulumi.String("attribute"),
						ThingName: pulumi.String("thingName"),
						RoleArn:   pulumi.String("arn:aws:iam::<your_Account_Id>:role/Enrich"),
						Next:      pulumi.String("DeviceShadowEnrichActivity"),
					},
					DeviceShadowEnrich: &iotanalytics.PipelineDeviceShadowEnrichArgs{
						Name:      pulumi.String("DeviceShadowEnrichActivity"),
						Attribute: pulumi.String("attribute"),
						ThingName: pulumi.String("thingName"),
						RoleArn:   pulumi.String("arn:aws:iam::<your_Account_Id>:role/Enrich"),
						Next:      pulumi.String("DatastoreActivity"),
					},
					Datastore: &iotanalytics.PipelineDatastoreArgs{
						Name:          pulumi.String("DatastoreActivity"),
						DatastoreName: pulumi.String("Datastore"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

Coming soon!

import pulumi
import pulumi_aws_native as aws_native

pipeline = aws_native.iotanalytics.Pipeline("pipeline",
    pipeline_name="ComplexPipeline",
    pipeline_activities=[aws_native.iotanalytics.PipelineActivityArgs(
        channel=aws_native.iotanalytics.PipelineChannelArgs(
            name="ChannelActivity",
            channel_name="Channel",
            next="LambdaActivity",
        ),
        lambda_=aws_native.iotanalytics.PipelineLambdaArgs(
            name="LambdaActivity",
            lambda_name="Lambda",
            batch_size=1,
            next="AddAttributesActivity",
        ),
        add_attributes=aws_native.iotanalytics.PipelineAddAttributesArgs(
            name="AddAttributesActivity",
            attributes={
                "key1": "attribute1",
                "key2": "attribute2",
            },
            next="RemoveAttributesActivity",
        ),
        remove_attributes=aws_native.iotanalytics.PipelineRemoveAttributesArgs(
            name="RemoveAttributesActivity",
            attributes=[
                "attribute1",
                "attribute2",
            ],
            next="SelectAttributesActivity",
        ),
        select_attributes=aws_native.iotanalytics.PipelineSelectAttributesArgs(
            name="SelectAttributesActivity",
            attributes=[
                "attribute1",
                "attribute2",
            ],
            next="FilterActivity",
        ),
        filter=aws_native.iotanalytics.PipelineFilterArgs(
            name="FilterActivity",
            filter="attribute1 > 40 AND attribute2 < 20",
            next="MathActivity",
        ),
        math=aws_native.iotanalytics.PipelineMathArgs(
            name="MathActivity",
            attribute="attribute",
            math="attribute - 10",
            next="DeviceRegistryEnrichActivity",
        ),
        device_registry_enrich=aws_native.iotanalytics.PipelineDeviceRegistryEnrichArgs(
            name="DeviceRegistryEnrichActivity",
            attribute="attribute",
            thing_name="thingName",
            role_arn="arn:aws:iam::<your_Account_Id>:role/Enrich",
            next="DeviceShadowEnrichActivity",
        ),
        device_shadow_enrich=aws_native.iotanalytics.PipelineDeviceShadowEnrichArgs(
            name="DeviceShadowEnrichActivity",
            attribute="attribute",
            thing_name="thingName",
            role_arn="arn:aws:iam::<your_Account_Id>:role/Enrich",
            next="DatastoreActivity",
        ),
        datastore=aws_native.iotanalytics.PipelineDatastoreArgs(
            name="DatastoreActivity",
            datastore_name="Datastore",
        ),
    )])

import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";

const pipeline = new aws_native.iotanalytics.Pipeline("pipeline", {
    pipelineName: "ComplexPipeline",
    pipelineActivities: [{
        channel: {
            name: "ChannelActivity",
            channelName: "Channel",
            next: "LambdaActivity",
        },
        lambda: {
            name: "LambdaActivity",
            lambdaName: "Lambda",
            batchSize: 1,
            next: "AddAttributesActivity",
        },
        addAttributes: {
            name: "AddAttributesActivity",
            attributes: {
                key1: "attribute1",
                key2: "attribute2",
            },
            next: "RemoveAttributesActivity",
        },
        removeAttributes: {
            name: "RemoveAttributesActivity",
            attributes: [
                "attribute1",
                "attribute2",
            ],
            next: "SelectAttributesActivity",
        },
        selectAttributes: {
            name: "SelectAttributesActivity",
            attributes: [
                "attribute1",
                "attribute2",
            ],
            next: "FilterActivity",
        },
        filter: {
            name: "FilterActivity",
            filter: "attribute1 > 40 AND attribute2 < 20",
            next: "MathActivity",
        },
        math: {
            name: "MathActivity",
            attribute: "attribute",
            math: "attribute - 10",
            next: "DeviceRegistryEnrichActivity",
        },
        deviceRegistryEnrich: {
            name: "DeviceRegistryEnrichActivity",
            attribute: "attribute",
            thingName: "thingName",
            roleArn: "arn:aws:iam::<your_Account_Id>:role/Enrich",
            next: "DeviceShadowEnrichActivity",
        },
        deviceShadowEnrich: {
            name: "DeviceShadowEnrichActivity",
            attribute: "attribute",
            thingName: "thingName",
            roleArn: "arn:aws:iam::<your_Account_Id>:role/Enrich",
            next: "DatastoreActivity",
        },
        datastore: {
            name: "DatastoreActivity",
            datastoreName: "Datastore",
        },
    }],
});

Coming soon!

Create Pipeline Resource

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

Constructor syntax

new Pipeline(name: string, args: PipelineArgs, opts?: CustomResourceOptions);

@overload
def Pipeline(resource_name: str,
             args: PipelineArgs,
             opts: Optional[ResourceOptions] = None)

@overload
def Pipeline(resource_name: str,
             opts: Optional[ResourceOptions] = None,
             pipeline_activities: Optional[Sequence[PipelineActivityArgs]] = None,
             pipeline_name: Optional[str] = None,
             tags: Optional[Sequence[_root_inputs.TagArgs]] = None)

func NewPipeline(ctx *Context, name string, args PipelineArgs, opts ...ResourceOption) (*Pipeline, error)

public Pipeline(string name, PipelineArgs args, CustomResourceOptions? opts = null)

public Pipeline(String name, PipelineArgs args)
public Pipeline(String name, PipelineArgs args, CustomResourceOptions options)

type: aws-native:iotanalytics:Pipeline
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 PipelineArgs: 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 PipelineArgs: 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 PipelineArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

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

name String: The unique name of the resource.
args PipelineArgs: The arguments to resource properties.
options CustomResourceOptions: Bag of options to control resource's behavior.

Example

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

Coming soon!

Coming soon!

Coming soon!

Coming soon!

const aws_nativePipelineResource = new aws_native.iotanalytics.Pipeline("aws-nativePipelineResource", {
    pipelineActivities: [{
        addAttributes: {
            attributes: {
                string: "string",
            },
            name: "string",
            next: "string",
        },
        channel: {
            channelName: "string",
            name: "string",
            next: "string",
        },
        datastore: {
            datastoreName: "string",
            name: "string",
        },
        deviceRegistryEnrich: {
            attribute: "string",
            name: "string",
            roleArn: "string",
            thingName: "string",
            next: "string",
        },
        deviceShadowEnrich: {
            attribute: "string",
            name: "string",
            roleArn: "string",
            thingName: "string",
            next: "string",
        },
        filter: {
            filter: "string",
            name: "string",
            next: "string",
        },
        lambda: {
            batchSize: 0,
            lambdaName: "string",
            name: "string",
            next: "string",
        },
        math: {
            attribute: "string",
            math: "string",
            name: "string",
            next: "string",
        },
        removeAttributes: {
            attributes: ["string"],
            name: "string",
            next: "string",
        },
        selectAttributes: {
            attributes: ["string"],
            name: "string",
            next: "string",
        },
    }],
    pipelineName: "string",
    tags: [{
        key: "string",
        value: "string",
    }],
});

Coming soon!

Pipeline Resource Properties

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

Inputs

The Pipeline resource accepts the following input properties:

PipelineActivities List<Pulumi.AwsNative.IoTAnalytics.Inputs.PipelineActivity>
PipelineName string
Tags List<Pulumi.AwsNative.Inputs.Tag>

PipelineActivities []PipelineActivityArgs
PipelineName string
Tags TagArgs

pipelineActivities List<PipelineActivity>
pipelineName String
tags List<Tag>

pipelineActivities PipelineActivity[]
pipelineName string
tags Tag[]

pipeline_activities Sequence[PipelineActivityArgs]
pipeline_name str
tags Sequence[TagArgs]

pipelineActivities List<Property Map>
pipelineName String
tags List<Property Map>

Outputs

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

AwsId string
Id string: The provider-assigned unique ID for this managed resource.

AwsId string
Id string: The provider-assigned unique ID for this managed resource.

awsId String
id String: The provider-assigned unique ID for this managed resource.

awsId string
id string: The provider-assigned unique ID for this managed resource.

aws_id str
id str: The provider-assigned unique ID for this managed resource.

awsId String
id String: The provider-assigned unique ID for this managed resource.

Supporting Types

PipelineActivity, PipelineActivityArgs

PipelineAddAttributes, PipelineAddAttributesArgs

Attributes Dictionary<string, string>
Name string
Next string

Attributes map[string]string
Name string
Next string

attributes Map<String,String>
name String
next String

attributes {[key: string]: string}
name string
next string

attributes Mapping[str, str]
name str
next str

attributes Map<String>
name String
next String

PipelineChannel, PipelineChannelArgs

ChannelName string
Name string
Next string

ChannelName string
Name string
Next string

channelName String
name String
next String

channelName string
name string
next string

channel_name str
name str
next str

channelName String
name String
next String

PipelineDatastore, PipelineDatastoreArgs

DatastoreName string
Name string

DatastoreName string
Name string

datastoreName String
name String

datastoreName string
name string

datastore_name str
name str

datastoreName String
name String

PipelineDeviceRegistryEnrich, PipelineDeviceRegistryEnrichArgs

Attribute string
Name string
RoleArn string
ThingName string
Next string

Attribute string
Name string
RoleArn string
ThingName string
Next string

attribute String
name String
roleArn String
thingName String
next String

attribute string
name string
roleArn string
thingName string
next string

attribute str
name str
role_arn str
thing_name str
next str

attribute String
name String
roleArn String
thingName String
next String

PipelineDeviceShadowEnrich, PipelineDeviceShadowEnrichArgs

Attribute string
Name string
RoleArn string
ThingName string
Next string

Attribute string
Name string
RoleArn string
ThingName string
Next string

attribute String
name String
roleArn String
thingName String
next String

attribute string
name string
roleArn string
thingName string
next string

attribute str
name str
role_arn str
thing_name str
next str

attribute String
name String
roleArn String
thingName String
next String

PipelineFilter, PipelineFilterArgs

Filter string
Name string
Next string

Filter string
Name string
Next string

filter String
name String
next String

filter string
name string
next string

filter str
name str
next str

filter String
name String
next String

PipelineLambda, PipelineLambdaArgs

BatchSize int
LambdaName string
Name string
Next string

BatchSize int
LambdaName string
Name string
Next string

batchSize Integer
lambdaName String
name String
next String

batchSize number
lambdaName string
name string
next string

batch_size int
lambda_name str
name str
next str

batchSize Number
lambdaName String
name String
next String

PipelineMath, PipelineMathArgs

Attribute string
Math string
Name string
Next string

Attribute string
Math string
Name string
Next string

attribute String
math String
name String
next String

attribute string
math string
name string
next string

attribute str
math str
name str
next str

attribute String
math String
name String
next String

PipelineRemoveAttributes, PipelineRemoveAttributesArgs

Attributes List<string>
Name string
Next string

Attributes []string
Name string
Next string

attributes List<String>
name String
next String

attributes string[]
name string
next string

attributes Sequence[str]
name str
next str

attributes List<String>
name String
next String

PipelineSelectAttributes, PipelineSelectAttributesArgs

Attributes List<string>
Name string
Next string

Attributes []string
Name string
Next string

attributes List<String>
name String
next String

attributes string[]
name string
next string

attributes Sequence[str]
name str
next str

attributes List<String>
name String
next String

Tag, TagArgs

Key string: The key name of the tag
Value string: The value of the tag

Key string: The key name of the tag
Value string: The value of the tag

key String: The key name of the tag
value String: The value of the tag

key string: The key name of the tag
value string: The value of the tag

key str: The key name of the tag
value str: The value of the tag

key String: The key name of the tag
value String: The value of the tag

Package Details

Repository: AWS Native pulumi/pulumi-aws-native
License: Apache-2.0

AWS Native is in preview. AWS Classic is fully supported.

AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi

pulumi/pulumi-aws-native

aws-native.iotanalytics.Pipeline

On this page

On this page

Example Usage

Example

Example

Example

Example

Create Pipeline Resource

Constructor syntax

Parameters

Example

Pipeline Resource Properties

Inputs

Outputs

Supporting Types

PipelineActivity, PipelineActivityArgs

PipelineAddAttributes, PipelineAddAttributesArgs

PipelineChannel, PipelineChannelArgs

PipelineDatastore, PipelineDatastoreArgs

PipelineDeviceRegistryEnrich, PipelineDeviceRegistryEnrichArgs

PipelineDeviceShadowEnrich, PipelineDeviceShadowEnrichArgs

PipelineFilter, PipelineFilterArgs

PipelineLambda, PipelineLambdaArgs

PipelineMath, PipelineMathArgs

PipelineRemoveAttributes, PipelineRemoveAttributesArgs

PipelineSelectAttributes, PipelineSelectAttributesArgs

Tag, TagArgs

Package Details

On this page

On this page