azure-native.iotoperations.DataFlow

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

return await Deployment.RunAsync(() => 
{
    var dataFlow = new AzureNative.IoTOperations.DataFlow("dataFlow", new()
    {
        DataflowName = "aio-dataflow",
        DataflowProfileName = "aio-dataflowprofile",
        ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
        {
            Name = "ycsyubcxttlusbhfdqaynmkaatnbyv",
            Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
        },
        InstanceName = "aio-instance",
        Properties = new AzureNative.IoTOperations.Inputs.DataFlowPropertiesArgs
        {
            Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
            Operations = new[]
            {
                new AzureNative.IoTOperations.Inputs.DataFlowOperationArgs
                {
                    BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationArgs
                    {
                        Datasets = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationDatasetArgs
                            {
                                Description = "a description of this dataset",
                                Expression = "$2 == $1",
                                Inputs = new[]
                                {
                                    "machineId",
                                    "$context(dataset-name-user-provided1).machine.details.id",
                                },
                                Key = "dataset-name-user-provided1",
                                SchemaRef = "schemaRef-pointing-to-AIO-schema-registry-instance",
                            },
                        },
                        Filter = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationFilterArgs
                            {
                                Description = "this is a user generated string to provide context",
                                Expression = "$1 == $3  && $2 > $4",
                                Inputs = new[]
                                {
                                    "machineId",
                                    "temperature",
                                    "$context(dataset-name-user-provided1).machine.details.id",
                                    "$context(dataset-name-user-provided2).machine.location.temperature",
                                },
                                Type = AzureNative.IoTOperations.FilterType.Filter,
                            },
                        },
                        Map = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMapArgs
                            {
                                Description = "this is a user generated string to provide context for the operation",
                                Expression = "400",
                                Inputs = new() { },
                                Output = "temperatureLimit",
                                Type = AzureNative.IoTOperations.DataFlowMappingType.NewProperties,
                            },
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMapArgs
                            {
                                Description = "this is a user generated string to provide context for the operation",
                                Expression = "$1 * 1000",
                                Inputs = new[]
                                {
                                    "speed ? $last",
                                },
                                Output = "speedLKV",
                            },
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMapArgs
                            {
                                Description = "this is a user generated string to provide context for the operation",
                                Expression = "$1 * 9/5 + 32",
                                Inputs = new[]
                                {
                                    "temperature",
                                },
                                Output = "temperatureF",
                                Type = AzureNative.IoTOperations.DataFlowMappingType.Compute,
                            },
                        },
                        SchemaRef = "kszdaahrhhctjvusgakiz",
                        SerializationFormat = AzureNative.IoTOperations.TransformationSerializationFormat.Delta,
                    },
                    DestinationSettings = new AzureNative.IoTOperations.Inputs.DataFlowDestinationOperationArgs
                    {
                        DataDestination = "hxwohipwddccefqrdz",
                        EndpointRef = "hvexewvu",
                    },
                    Name = "hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau",
                    OperationType = AzureNative.IoTOperations.OperationType.Source,
                    SourceSettings = new AzureNative.IoTOperations.Inputs.DataFlowSourceOperationArgs
                    {
                        AssetRef = "eswnjlnapfrdeklaivntm",
                        DataSources = new[]
                        {
                            "dvncbklqkvjygnjgatioaikaneue",
                        },
                        EndpointRef = "cqsvkqeuyjzci",
                        SchemaRef = "uchmgqpworewvayionuwydneotyo",
                        SerializationFormat = AzureNative.IoTOperations.SourceSerializationFormat.Json,
                    },
                },
            },
            ProfileRef = "juecrpocwpcajelwiwrplvacf",
        },
        ResourceGroupName = "rgiotoperations",
    });

});

package main

import (
	iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := iotoperations.NewDataFlow(ctx, "dataFlow", &iotoperations.DataFlowArgs{
			DataflowName:        pulumi.String("aio-dataflow"),
			DataflowProfileName: pulumi.String("aio-dataflowprofile"),
			ExtendedLocation: &iotoperations.ExtendedLocationArgs{
				Name: pulumi.String("ycsyubcxttlusbhfdqaynmkaatnbyv"),
				Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
			},
			InstanceName: pulumi.String("aio-instance"),
			Properties: &iotoperations.DataFlowPropertiesArgs{
				Mode: pulumi.String(iotoperations.OperationalModeEnabled),
				Operations: iotoperations.DataFlowOperationArray{
					&iotoperations.DataFlowOperationArgs{
						BuiltInTransformationSettings: &iotoperations.DataFlowBuiltInTransformationArgs{
							Datasets: iotoperations.DataFlowBuiltInTransformationDatasetArray{
								&iotoperations.DataFlowBuiltInTransformationDatasetArgs{
									Description: pulumi.String("a description of this dataset"),
									Expression:  pulumi.String("$2 == $1"),
									Inputs: pulumi.StringArray{
										pulumi.String("machineId"),
										pulumi.String("$context(dataset-name-user-provided1).machine.details.id"),
									},
									Key:       pulumi.String("dataset-name-user-provided1"),
									SchemaRef: pulumi.String("schemaRef-pointing-to-AIO-schema-registry-instance"),
								},
							},
							Filter: iotoperations.DataFlowBuiltInTransformationFilterArray{
								&iotoperations.DataFlowBuiltInTransformationFilterArgs{
									Description: pulumi.String("this is a user generated string to provide context"),
									Expression:  pulumi.String("$1 == $3  && $2 > $4"),
									Inputs: pulumi.StringArray{
										pulumi.String("machineId"),
										pulumi.String("temperature"),
										pulumi.String("$context(dataset-name-user-provided1).machine.details.id"),
										pulumi.String("$context(dataset-name-user-provided2).machine.location.temperature"),
									},
									Type: pulumi.String(iotoperations.FilterTypeFilter),
								},
							},
							Map: iotoperations.DataFlowBuiltInTransformationMapArray{
								&iotoperations.DataFlowBuiltInTransformationMapArgs{
									Description: pulumi.String("this is a user generated string to provide context for the operation"),
									Expression:  pulumi.String("400"),
									Inputs:      pulumi.StringArray{},
									Output:      pulumi.String("temperatureLimit"),
									Type:        pulumi.String(iotoperations.DataFlowMappingTypeNewProperties),
								},
								&iotoperations.DataFlowBuiltInTransformationMapArgs{
									Description: pulumi.String("this is a user generated string to provide context for the operation"),
									Expression:  pulumi.String("$1 * 1000"),
									Inputs: pulumi.StringArray{
										pulumi.String("speed ? $last"),
									},
									Output: pulumi.String("speedLKV"),
								},
								&iotoperations.DataFlowBuiltInTransformationMapArgs{
									Description: pulumi.String("this is a user generated string to provide context for the operation"),
									Expression:  pulumi.String("$1 * 9/5 + 32"),
									Inputs: pulumi.StringArray{
										pulumi.String("temperature"),
									},
									Output: pulumi.String("temperatureF"),
									Type:   pulumi.String(iotoperations.DataFlowMappingTypeCompute),
								},
							},
							SchemaRef:           pulumi.String("kszdaahrhhctjvusgakiz"),
							SerializationFormat: pulumi.String(iotoperations.TransformationSerializationFormatDelta),
						},
						DestinationSettings: &iotoperations.DataFlowDestinationOperationArgs{
							DataDestination: pulumi.String("hxwohipwddccefqrdz"),
							EndpointRef:     pulumi.String("hvexewvu"),
						},
						Name:          pulumi.String("hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau"),
						OperationType: pulumi.String(iotoperations.OperationTypeSource),
						SourceSettings: &iotoperations.DataFlowSourceOperationArgs{
							AssetRef: pulumi.String("eswnjlnapfrdeklaivntm"),
							DataSources: pulumi.StringArray{
								pulumi.String("dvncbklqkvjygnjgatioaikaneue"),
							},
							EndpointRef:         pulumi.String("cqsvkqeuyjzci"),
							SchemaRef:           pulumi.String("uchmgqpworewvayionuwydneotyo"),
							SerializationFormat: pulumi.String(iotoperations.SourceSerializationFormatJson),
						},
					},
				},
				ProfileRef: pulumi.String("juecrpocwpcajelwiwrplvacf"),
			},
			ResourceGroupName: pulumi.String("rgiotoperations"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.DataFlow;
import com.pulumi.azurenative.iotoperations.DataFlowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataFlowPropertiesArgs;
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 dataFlow = new DataFlow("dataFlow", DataFlowArgs.builder()
            .dataflowName("aio-dataflow")
            .dataflowProfileName("aio-dataflowprofile")
            .extendedLocation(ExtendedLocationArgs.builder()
                .name("ycsyubcxttlusbhfdqaynmkaatnbyv")
                .type("CustomLocation")
                .build())
            .instanceName("aio-instance")
            .properties(DataFlowPropertiesArgs.builder()
                .mode("Enabled")
                .operations(DataFlowOperationArgs.builder()
                    .builtInTransformationSettings(DataFlowBuiltInTransformationArgs.builder()
                        .datasets(DataFlowBuiltInTransformationDatasetArgs.builder()
                            .description("a description of this dataset")
                            .expression("$2 == $1")
                            .inputs(                            
                                "machineId",
                                "$context(dataset-name-user-provided1).machine.details.id")
                            .key("dataset-name-user-provided1")
                            .schemaRef("schemaRef-pointing-to-AIO-schema-registry-instance")
                            .build())
                        .filter(DataFlowBuiltInTransformationFilterArgs.builder()
                            .description("this is a user generated string to provide context")
                            .expression("$1 == $3  && $2 > $4")
                            .inputs(                            
                                "machineId",
                                "temperature",
                                "$context(dataset-name-user-provided1).machine.details.id",
                                "$context(dataset-name-user-provided2).machine.location.temperature")
                            .type("Filter")
                            .build())
                        .map(                        
                            DataFlowBuiltInTransformationMapArgs.builder()
                                .description("this is a user generated string to provide context for the operation")
                                .expression("400")
                                .inputs()
                                .output("temperatureLimit")
                                .type("NewProperties")
                                .build(),
                            DataFlowBuiltInTransformationMapArgs.builder()
                                .description("this is a user generated string to provide context for the operation")
                                .expression("$1 * 1000")
                                .inputs("speed ? $last")
                                .output("speedLKV")
                                .build(),
                            DataFlowBuiltInTransformationMapArgs.builder()
                                .description("this is a user generated string to provide context for the operation")
                                .expression("$1 * 9/5 + 32")
                                .inputs("temperature")
                                .output("temperatureF")
                                .type("Compute")
                                .build())
                        .schemaRef("kszdaahrhhctjvusgakiz")
                        .serializationFormat("Delta")
                        .build())
                    .destinationSettings(DataFlowDestinationOperationArgs.builder()
                        .dataDestination("hxwohipwddccefqrdz")
                        .endpointRef("hvexewvu")
                        .build())
                    .name("hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau")
                    .operationType("Source")
                    .sourceSettings(DataFlowSourceOperationArgs.builder()
                        .assetRef("eswnjlnapfrdeklaivntm")
                        .dataSources("dvncbklqkvjygnjgatioaikaneue")
                        .endpointRef("cqsvkqeuyjzci")
                        .schemaRef("uchmgqpworewvayionuwydneotyo")
                        .serializationFormat("Json")
                        .build())
                    .build())
                .profileRef("juecrpocwpcajelwiwrplvacf")
                .build())
            .resourceGroupName("rgiotoperations")
            .build());

    }
}

import pulumi
import pulumi_azure_native as azure_native

data_flow = azure_native.iotoperations.DataFlow("dataFlow",
    dataflow_name="aio-dataflow",
    dataflow_profile_name="aio-dataflowprofile",
    extended_location={
        "name": "ycsyubcxttlusbhfdqaynmkaatnbyv",
        "type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
    },
    instance_name="aio-instance",
    properties={
        "mode": azure_native.iotoperations.OperationalMode.ENABLED,
        "operations": [{
            "built_in_transformation_settings": {
                "datasets": [{
                    "description": "a description of this dataset",
                    "expression": "$2 == $1",
                    "inputs": [
                        "machineId",
                        "$context(dataset-name-user-provided1).machine.details.id",
                    ],
                    "key": "dataset-name-user-provided1",
                    "schema_ref": "schemaRef-pointing-to-AIO-schema-registry-instance",
                }],
                "filter": [{
                    "description": "this is a user generated string to provide context",
                    "expression": "$1 == $3  && $2 > $4",
                    "inputs": [
                        "machineId",
                        "temperature",
                        "$context(dataset-name-user-provided1).machine.details.id",
                        "$context(dataset-name-user-provided2).machine.location.temperature",
                    ],
                    "type": azure_native.iotoperations.FilterType.FILTER,
                }],
                "map": [
                    {
                        "description": "this is a user generated string to provide context for the operation",
                        "expression": "400",
                        "inputs": [],
                        "output": "temperatureLimit",
                        "type": azure_native.iotoperations.DataFlowMappingType.NEW_PROPERTIES,
                    },
                    {
                        "description": "this is a user generated string to provide context for the operation",
                        "expression": "$1 * 1000",
                        "inputs": ["speed ? $last"],
                        "output": "speedLKV",
                    },
                    {
                        "description": "this is a user generated string to provide context for the operation",
                        "expression": "$1 * 9/5 + 32",
                        "inputs": ["temperature"],
                        "output": "temperatureF",
                        "type": azure_native.iotoperations.DataFlowMappingType.COMPUTE,
                    },
                ],
                "schema_ref": "kszdaahrhhctjvusgakiz",
                "serialization_format": azure_native.iotoperations.TransformationSerializationFormat.DELTA,
            },
            "destination_settings": {
                "data_destination": "hxwohipwddccefqrdz",
                "endpoint_ref": "hvexewvu",
            },
            "name": "hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau",
            "operation_type": azure_native.iotoperations.OperationType.SOURCE,
            "source_settings": {
                "asset_ref": "eswnjlnapfrdeklaivntm",
                "data_sources": ["dvncbklqkvjygnjgatioaikaneue"],
                "endpoint_ref": "cqsvkqeuyjzci",
                "schema_ref": "uchmgqpworewvayionuwydneotyo",
                "serialization_format": azure_native.iotoperations.SourceSerializationFormat.JSON,
            },
        }],
        "profile_ref": "juecrpocwpcajelwiwrplvacf",
    },
    resource_group_name="rgiotoperations")

import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";

const dataFlow = new azure_native.iotoperations.DataFlow("dataFlow", {
    dataflowName: "aio-dataflow",
    dataflowProfileName: "aio-dataflowprofile",
    extendedLocation: {
        name: "ycsyubcxttlusbhfdqaynmkaatnbyv",
        type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
    },
    instanceName: "aio-instance",
    properties: {
        mode: azure_native.iotoperations.OperationalMode.Enabled,
        operations: [{
            builtInTransformationSettings: {
                datasets: [{
                    description: "a description of this dataset",
                    expression: "$2 == $1",
                    inputs: [
                        "machineId",
                        "$context(dataset-name-user-provided1).machine.details.id",
                    ],
                    key: "dataset-name-user-provided1",
                    schemaRef: "schemaRef-pointing-to-AIO-schema-registry-instance",
                }],
                filter: [{
                    description: "this is a user generated string to provide context",
                    expression: "$1 == $3  && $2 > $4",
                    inputs: [
                        "machineId",
                        "temperature",
                        "$context(dataset-name-user-provided1).machine.details.id",
                        "$context(dataset-name-user-provided2).machine.location.temperature",
                    ],
                    type: azure_native.iotoperations.FilterType.Filter,
                }],
                map: [
                    {
                        description: "this is a user generated string to provide context for the operation",
                        expression: "400",
                        inputs: [],
                        output: "temperatureLimit",
                        type: azure_native.iotoperations.DataFlowMappingType.NewProperties,
                    },
                    {
                        description: "this is a user generated string to provide context for the operation",
                        expression: "$1 * 1000",
                        inputs: ["speed ? $last"],
                        output: "speedLKV",
                    },
                    {
                        description: "this is a user generated string to provide context for the operation",
                        expression: "$1 * 9/5 + 32",
                        inputs: ["temperature"],
                        output: "temperatureF",
                        type: azure_native.iotoperations.DataFlowMappingType.Compute,
                    },
                ],
                schemaRef: "kszdaahrhhctjvusgakiz",
                serializationFormat: azure_native.iotoperations.TransformationSerializationFormat.Delta,
            },
            destinationSettings: {
                dataDestination: "hxwohipwddccefqrdz",
                endpointRef: "hvexewvu",
            },
            name: "hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau",
            operationType: azure_native.iotoperations.OperationType.Source,
            sourceSettings: {
                assetRef: "eswnjlnapfrdeklaivntm",
                dataSources: ["dvncbklqkvjygnjgatioaikaneue"],
                endpointRef: "cqsvkqeuyjzci",
                schemaRef: "uchmgqpworewvayionuwydneotyo",
                serializationFormat: azure_native.iotoperations.SourceSerializationFormat.Json,
            },
        }],
        profileRef: "juecrpocwpcajelwiwrplvacf",
    },
    resourceGroupName: "rgiotoperations",
});

resources:
  dataFlow:
    type: azure-native:iotoperations:DataFlow
    properties:
      dataflowName: aio-dataflow
      dataflowProfileName: aio-dataflowprofile
      extendedLocation:
        name: ycsyubcxttlusbhfdqaynmkaatnbyv
        type: CustomLocation
      instanceName: aio-instance
      properties:
        mode: Enabled
        operations:
          - builtInTransformationSettings:
              datasets:
                - description: a description of this dataset
                  expression: $2 == $1
                  inputs:
                    - machineId
                    - $context(dataset-name-user-provided1).machine.details.id
                  key: dataset-name-user-provided1
                  schemaRef: schemaRef-pointing-to-AIO-schema-registry-instance
              filter:
                - description: this is a user generated string to provide context
                  expression: $1 == $3  && $2 > $4
                  inputs:
                    - machineId
                    - temperature
                    - $context(dataset-name-user-provided1).machine.details.id
                    - $context(dataset-name-user-provided2).machine.location.temperature
                  type: Filter
              map:
                - description: this is a user generated string to provide context for the operation
                  expression: '400'
                  inputs: []
                  output: temperatureLimit
                  type: NewProperties
                - description: this is a user generated string to provide context for the operation
                  expression: $1 * 1000
                  inputs:
                    - speed ? $last
                  output: speedLKV
                - description: this is a user generated string to provide context for the operation
                  expression: $1 * 9/5 + 32
                  inputs:
                    - temperature
                  output: temperatureF
                  type: Compute
              schemaRef: kszdaahrhhctjvusgakiz
              serializationFormat: Delta
            destinationSettings:
              dataDestination: hxwohipwddccefqrdz
              endpointRef: hvexewvu
            name: hhoeuttlpjucxldumilbdbxsglpfhvamwrasjuroucjzutjamarau
            operationType: Source
            sourceSettings:
              assetRef: eswnjlnapfrdeklaivntm
              dataSources:
                - dvncbklqkvjygnjgatioaikaneue
              endpointRef: cqsvkqeuyjzci
              schemaRef: uchmgqpworewvayionuwydneotyo
              serializationFormat: Json
        profileRef: juecrpocwpcajelwiwrplvacf
      resourceGroupName: rgiotoperations