1. Packages
  2. AWS Native
  3. API Docs
  4. iotanalytics
  5. Pipeline

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

AWS Native v0.97.0 published on Wednesday, Feb 21, 2024 by Pulumi

aws-native.iotanalytics.Pipeline

Explore with Pulumi AI

aws-native logo

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

AWS Native v0.97.0 published on Wednesday, Feb 21, 2024 by Pulumi

    Resource Type definition for AWS::IoTAnalytics::Pipeline

    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{
    interface{}{
    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{
    interface{}{
    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{
    interface{}{
    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{
    interface{}{
    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

    new Pipeline(name: string, args: PipelineArgs, opts?: CustomResourceOptions);
    @overload
    def Pipeline(resource_name: str,
                 opts: Optional[ResourceOptions] = None,
                 pipeline_activities: Optional[Sequence[PipelineActivityArgs]] = None,
                 pipeline_name: Optional[str] = None,
                 tags: Optional[Sequence[PipelineTagArgs]] = None)
    @overload
    def Pipeline(resource_name: str,
                 args: PipelineArgs,
                 opts: Optional[ResourceOptions] = 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.
    
    
    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.

    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:

    Outputs

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

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    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
    channelName String
    name String
    next String

    PipelineDatastore, PipelineDatastoreArgs

    DatastoreName string
    Name string
    DatastoreName string
    Name string
    datastoreName String
    name String
    datastoreName string
    name string
    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 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 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
    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

    PipelineTag, PipelineTagArgs

    Key string
    Value string
    Key string
    Value string
    key String
    value String
    key string
    value string
    key str
    value str
    key String
    value String

    Package Details

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

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

    AWS Native v0.97.0 published on Wednesday, Feb 21, 2024 by Pulumi