1. Packages
  2. Azure Native
  3. API Docs
  4. iotoperations
  5. DataFlow
This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
Azure Native v2.77.0 published on Thursday, Dec 12, 2024 by Pulumi

azure-native.iotoperations.DataFlow

Explore with Pulumi AI

azure-native logo
This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
Azure Native v2.77.0 published on Thursday, Dec 12, 2024 by Pulumi

    Instance dataflowProfile dataflow resource Azure REST API version: 2024-07-01-preview.

    Example Usage

    DataFlow_CreateOrUpdate

    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
    

    Create DataFlow Resource

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

    Constructor syntax

    new DataFlow(name: string, args: DataFlowArgs, opts?: CustomResourceOptions);
    @overload
    def DataFlow(resource_name: str,
                 args: DataFlowArgs,
                 opts: Optional[ResourceOptions] = None)
    
    @overload
    def DataFlow(resource_name: str,
                 opts: Optional[ResourceOptions] = None,
                 dataflow_profile_name: Optional[str] = None,
                 extended_location: Optional[ExtendedLocationArgs] = None,
                 instance_name: Optional[str] = None,
                 resource_group_name: Optional[str] = None,
                 dataflow_name: Optional[str] = None,
                 properties: Optional[DataFlowPropertiesArgs] = None)
    func NewDataFlow(ctx *Context, name string, args DataFlowArgs, opts ...ResourceOption) (*DataFlow, error)
    public DataFlow(string name, DataFlowArgs args, CustomResourceOptions? opts = null)
    public DataFlow(String name, DataFlowArgs args)
    public DataFlow(String name, DataFlowArgs args, CustomResourceOptions options)
    
    type: azure-native:iotoperations:DataFlow
    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 DataFlowArgs
    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 DataFlowArgs
    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 DataFlowArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

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

    var azure_nativeDataFlowResource = new AzureNative.IoTOperations.DataFlow("azure-nativeDataFlowResource", new()
    {
        DataflowProfileName = "string",
        ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
        {
            Name = "string",
            Type = "string",
        },
        InstanceName = "string",
        ResourceGroupName = "string",
        DataflowName = "string",
        Properties = new AzureNative.IoTOperations.Inputs.DataFlowPropertiesArgs
        {
            Operations = new[]
            {
                new AzureNative.IoTOperations.Inputs.DataFlowOperationArgs
                {
                    DestinationSettings = new AzureNative.IoTOperations.Inputs.DataFlowDestinationOperationArgs
                    {
                        DataDestination = "string",
                        EndpointRef = "string",
                    },
                    OperationType = "string",
                    SourceSettings = new AzureNative.IoTOperations.Inputs.DataFlowSourceOperationArgs
                    {
                        DataSources = new[]
                        {
                            "string",
                        },
                        EndpointRef = "string",
                        AssetRef = "string",
                        SchemaRef = "string",
                        SerializationFormat = "string",
                    },
                    BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationArgs
                    {
                        Datasets = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationDatasetArgs
                            {
                                Inputs = new[]
                                {
                                    "string",
                                },
                                Key = "string",
                                Description = "string",
                                Expression = "string",
                                SchemaRef = "string",
                            },
                        },
                        Filter = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationFilterArgs
                            {
                                Expression = "string",
                                Inputs = new[]
                                {
                                    "string",
                                },
                                Description = "string",
                                Type = "string",
                            },
                        },
                        Map = new[]
                        {
                            new AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMapArgs
                            {
                                Inputs = new[]
                                {
                                    "string",
                                },
                                Output = "string",
                                Description = "string",
                                Expression = "string",
                                Type = "string",
                            },
                        },
                        SchemaRef = "string",
                        SerializationFormat = "string",
                    },
                    Name = "string",
                },
            },
            ProfileRef = "string",
            Mode = "string",
        },
    });
    
    example, err := iotoperations.NewDataFlow(ctx, "azure-nativeDataFlowResource", &iotoperations.DataFlowArgs{
    	DataflowProfileName: pulumi.String("string"),
    	ExtendedLocation: &iotoperations.ExtendedLocationArgs{
    		Name: pulumi.String("string"),
    		Type: pulumi.String("string"),
    	},
    	InstanceName:      pulumi.String("string"),
    	ResourceGroupName: pulumi.String("string"),
    	DataflowName:      pulumi.String("string"),
    	Properties: &iotoperations.DataFlowPropertiesArgs{
    		Operations: iotoperations.DataFlowOperationArray{
    			&iotoperations.DataFlowOperationArgs{
    				DestinationSettings: &iotoperations.DataFlowDestinationOperationArgs{
    					DataDestination: pulumi.String("string"),
    					EndpointRef:     pulumi.String("string"),
    				},
    				OperationType: pulumi.String("string"),
    				SourceSettings: &iotoperations.DataFlowSourceOperationArgs{
    					DataSources: pulumi.StringArray{
    						pulumi.String("string"),
    					},
    					EndpointRef:         pulumi.String("string"),
    					AssetRef:            pulumi.String("string"),
    					SchemaRef:           pulumi.String("string"),
    					SerializationFormat: pulumi.String("string"),
    				},
    				BuiltInTransformationSettings: &iotoperations.DataFlowBuiltInTransformationArgs{
    					Datasets: iotoperations.DataFlowBuiltInTransformationDatasetArray{
    						&iotoperations.DataFlowBuiltInTransformationDatasetArgs{
    							Inputs: pulumi.StringArray{
    								pulumi.String("string"),
    							},
    							Key:         pulumi.String("string"),
    							Description: pulumi.String("string"),
    							Expression:  pulumi.String("string"),
    							SchemaRef:   pulumi.String("string"),
    						},
    					},
    					Filter: iotoperations.DataFlowBuiltInTransformationFilterArray{
    						&iotoperations.DataFlowBuiltInTransformationFilterArgs{
    							Expression: pulumi.String("string"),
    							Inputs: pulumi.StringArray{
    								pulumi.String("string"),
    							},
    							Description: pulumi.String("string"),
    							Type:        pulumi.String("string"),
    						},
    					},
    					Map: iotoperations.DataFlowBuiltInTransformationMapArray{
    						&iotoperations.DataFlowBuiltInTransformationMapArgs{
    							Inputs: pulumi.StringArray{
    								pulumi.String("string"),
    							},
    							Output:      pulumi.String("string"),
    							Description: pulumi.String("string"),
    							Expression:  pulumi.String("string"),
    							Type:        pulumi.String("string"),
    						},
    					},
    					SchemaRef:           pulumi.String("string"),
    					SerializationFormat: pulumi.String("string"),
    				},
    				Name: pulumi.String("string"),
    			},
    		},
    		ProfileRef: pulumi.String("string"),
    		Mode:       pulumi.String("string"),
    	},
    })
    
    var azure_nativeDataFlowResource = new DataFlow("azure-nativeDataFlowResource", DataFlowArgs.builder()
        .dataflowProfileName("string")
        .extendedLocation(ExtendedLocationArgs.builder()
            .name("string")
            .type("string")
            .build())
        .instanceName("string")
        .resourceGroupName("string")
        .dataflowName("string")
        .properties(DataFlowPropertiesArgs.builder()
            .operations(DataFlowOperationArgs.builder()
                .destinationSettings(DataFlowDestinationOperationArgs.builder()
                    .dataDestination("string")
                    .endpointRef("string")
                    .build())
                .operationType("string")
                .sourceSettings(DataFlowSourceOperationArgs.builder()
                    .dataSources("string")
                    .endpointRef("string")
                    .assetRef("string")
                    .schemaRef("string")
                    .serializationFormat("string")
                    .build())
                .builtInTransformationSettings(DataFlowBuiltInTransformationArgs.builder()
                    .datasets(DataFlowBuiltInTransformationDatasetArgs.builder()
                        .inputs("string")
                        .key("string")
                        .description("string")
                        .expression("string")
                        .schemaRef("string")
                        .build())
                    .filter(DataFlowBuiltInTransformationFilterArgs.builder()
                        .expression("string")
                        .inputs("string")
                        .description("string")
                        .type("string")
                        .build())
                    .map(DataFlowBuiltInTransformationMapArgs.builder()
                        .inputs("string")
                        .output("string")
                        .description("string")
                        .expression("string")
                        .type("string")
                        .build())
                    .schemaRef("string")
                    .serializationFormat("string")
                    .build())
                .name("string")
                .build())
            .profileRef("string")
            .mode("string")
            .build())
        .build());
    
    azure_native_data_flow_resource = azure_native.iotoperations.DataFlow("azure-nativeDataFlowResource",
        dataflow_profile_name="string",
        extended_location={
            "name": "string",
            "type": "string",
        },
        instance_name="string",
        resource_group_name="string",
        dataflow_name="string",
        properties={
            "operations": [{
                "destination_settings": {
                    "data_destination": "string",
                    "endpoint_ref": "string",
                },
                "operation_type": "string",
                "source_settings": {
                    "data_sources": ["string"],
                    "endpoint_ref": "string",
                    "asset_ref": "string",
                    "schema_ref": "string",
                    "serialization_format": "string",
                },
                "built_in_transformation_settings": {
                    "datasets": [{
                        "inputs": ["string"],
                        "key": "string",
                        "description": "string",
                        "expression": "string",
                        "schema_ref": "string",
                    }],
                    "filter": [{
                        "expression": "string",
                        "inputs": ["string"],
                        "description": "string",
                        "type": "string",
                    }],
                    "map": [{
                        "inputs": ["string"],
                        "output": "string",
                        "description": "string",
                        "expression": "string",
                        "type": "string",
                    }],
                    "schema_ref": "string",
                    "serialization_format": "string",
                },
                "name": "string",
            }],
            "profile_ref": "string",
            "mode": "string",
        })
    
    const azure_nativeDataFlowResource = new azure_native.iotoperations.DataFlow("azure-nativeDataFlowResource", {
        dataflowProfileName: "string",
        extendedLocation: {
            name: "string",
            type: "string",
        },
        instanceName: "string",
        resourceGroupName: "string",
        dataflowName: "string",
        properties: {
            operations: [{
                destinationSettings: {
                    dataDestination: "string",
                    endpointRef: "string",
                },
                operationType: "string",
                sourceSettings: {
                    dataSources: ["string"],
                    endpointRef: "string",
                    assetRef: "string",
                    schemaRef: "string",
                    serializationFormat: "string",
                },
                builtInTransformationSettings: {
                    datasets: [{
                        inputs: ["string"],
                        key: "string",
                        description: "string",
                        expression: "string",
                        schemaRef: "string",
                    }],
                    filter: [{
                        expression: "string",
                        inputs: ["string"],
                        description: "string",
                        type: "string",
                    }],
                    map: [{
                        inputs: ["string"],
                        output: "string",
                        description: "string",
                        expression: "string",
                        type: "string",
                    }],
                    schemaRef: "string",
                    serializationFormat: "string",
                },
                name: "string",
            }],
            profileRef: "string",
            mode: "string",
        },
    });
    
    type: azure-native:iotoperations:DataFlow
    properties:
        dataflowName: string
        dataflowProfileName: string
        extendedLocation:
            name: string
            type: string
        instanceName: string
        properties:
            mode: string
            operations:
                - builtInTransformationSettings:
                    datasets:
                        - description: string
                          expression: string
                          inputs:
                            - string
                          key: string
                          schemaRef: string
                    filter:
                        - description: string
                          expression: string
                          inputs:
                            - string
                          type: string
                    map:
                        - description: string
                          expression: string
                          inputs:
                            - string
                          output: string
                          type: string
                    schemaRef: string
                    serializationFormat: string
                  destinationSettings:
                    dataDestination: string
                    endpointRef: string
                  name: string
                  operationType: string
                  sourceSettings:
                    assetRef: string
                    dataSources:
                        - string
                    endpointRef: string
                    schemaRef: string
                    serializationFormat: string
            profileRef: string
        resourceGroupName: string
    

    DataFlow Resource Properties

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

    Inputs

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

    The DataFlow resource accepts the following input properties:

    DataflowProfileName string
    Name of Instance dataflowProfile resource
    ExtendedLocation Pulumi.AzureNative.IoTOperations.Inputs.ExtendedLocation
    Edge location of the resource.
    InstanceName string
    Name of instance.
    ResourceGroupName string
    The name of the resource group. The name is case insensitive.
    DataflowName string
    Name of Instance dataflowProfile dataflow resource
    Properties Pulumi.AzureNative.IoTOperations.Inputs.DataFlowProperties
    The resource-specific properties for this resource.
    DataflowProfileName string
    Name of Instance dataflowProfile resource
    ExtendedLocation ExtendedLocationArgs
    Edge location of the resource.
    InstanceName string
    Name of instance.
    ResourceGroupName string
    The name of the resource group. The name is case insensitive.
    DataflowName string
    Name of Instance dataflowProfile dataflow resource
    Properties DataFlowPropertiesArgs
    The resource-specific properties for this resource.
    dataflowProfileName String
    Name of Instance dataflowProfile resource
    extendedLocation ExtendedLocation
    Edge location of the resource.
    instanceName String
    Name of instance.
    resourceGroupName String
    The name of the resource group. The name is case insensitive.
    dataflowName String
    Name of Instance dataflowProfile dataflow resource
    properties DataFlowProperties
    The resource-specific properties for this resource.
    dataflowProfileName string
    Name of Instance dataflowProfile resource
    extendedLocation ExtendedLocation
    Edge location of the resource.
    instanceName string
    Name of instance.
    resourceGroupName string
    The name of the resource group. The name is case insensitive.
    dataflowName string
    Name of Instance dataflowProfile dataflow resource
    properties DataFlowProperties
    The resource-specific properties for this resource.
    dataflow_profile_name str
    Name of Instance dataflowProfile resource
    extended_location ExtendedLocationArgs
    Edge location of the resource.
    instance_name str
    Name of instance.
    resource_group_name str
    The name of the resource group. The name is case insensitive.
    dataflow_name str
    Name of Instance dataflowProfile dataflow resource
    properties DataFlowPropertiesArgs
    The resource-specific properties for this resource.
    dataflowProfileName String
    Name of Instance dataflowProfile resource
    extendedLocation Property Map
    Edge location of the resource.
    instanceName String
    Name of instance.
    resourceGroupName String
    The name of the resource group. The name is case insensitive.
    dataflowName String
    Name of Instance dataflowProfile dataflow resource
    properties Property Map
    The resource-specific properties for this resource.

    Outputs

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

    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The name of the resource
    SystemData Pulumi.AzureNative.IoTOperations.Outputs.SystemDataResponse
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    Type string
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The name of the resource
    SystemData SystemDataResponse
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    Type string
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The name of the resource
    systemData SystemDataResponse
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    type String
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
    id string
    The provider-assigned unique ID for this managed resource.
    name string
    The name of the resource
    systemData SystemDataResponse
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    type string
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
    id str
    The provider-assigned unique ID for this managed resource.
    name str
    The name of the resource
    system_data SystemDataResponse
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    type str
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The name of the resource
    systemData Property Map
    Azure Resource Manager metadata containing createdBy and modifiedBy information.
    type String
    The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"

    Supporting Types

    DataFlowBuiltInTransformation, DataFlowBuiltInTransformationArgs

    Datasets List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationDataset>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    Filter List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationFilter>
    Filters input record or datapoints based on condition.
    Map List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMap>
    Maps input to output message.
    SchemaRef string
    Reference to the schema that describes the output of the transformation.
    SerializationFormat string | Pulumi.AzureNative.IoTOperations.TransformationSerializationFormat
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    Datasets []DataFlowBuiltInTransformationDataset
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    Filter []DataFlowBuiltInTransformationFilter
    Filters input record or datapoints based on condition.
    Map []DataFlowBuiltInTransformationMap
    Maps input to output message.
    SchemaRef string
    Reference to the schema that describes the output of the transformation.
    SerializationFormat string | TransformationSerializationFormat
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets List<DataFlowBuiltInTransformationDataset>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter List<DataFlowBuiltInTransformationFilter>
    Filters input record or datapoints based on condition.
    map List<DataFlowBuiltInTransformationMap>
    Maps input to output message.
    schemaRef String
    Reference to the schema that describes the output of the transformation.
    serializationFormat String | TransformationSerializationFormat
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets DataFlowBuiltInTransformationDataset[]
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter DataFlowBuiltInTransformationFilter[]
    Filters input record or datapoints based on condition.
    map DataFlowBuiltInTransformationMap[]
    Maps input to output message.
    schemaRef string
    Reference to the schema that describes the output of the transformation.
    serializationFormat string | TransformationSerializationFormat
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets Sequence[DataFlowBuiltInTransformationDataset]
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter Sequence[DataFlowBuiltInTransformationFilter]
    Filters input record or datapoints based on condition.
    map Sequence[DataFlowBuiltInTransformationMap]
    Maps input to output message.
    schema_ref str
    Reference to the schema that describes the output of the transformation.
    serialization_format str | TransformationSerializationFormat
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets List<Property Map>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter List<Property Map>
    Filters input record or datapoints based on condition.
    map List<Property Map>
    Maps input to output message.
    schemaRef String
    Reference to the schema that describes the output of the transformation.
    serializationFormat String | "Delta" | "Json" | "Parquet"
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json

    DataFlowBuiltInTransformationDataset, DataFlowBuiltInTransformationDatasetArgs

    Inputs List<string>
    List of fields for enriching from the Broker State Store.
    Key string
    The key of the dataset.
    Description string
    A user provided optional description of the dataset.
    Expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    SchemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    Inputs []string
    List of fields for enriching from the Broker State Store.
    Key string
    The key of the dataset.
    Description string
    A user provided optional description of the dataset.
    Expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    SchemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs List<String>
    List of fields for enriching from the Broker State Store.
    key String
    The key of the dataset.
    description String
    A user provided optional description of the dataset.
    expression String
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef String
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs string[]
    List of fields for enriching from the Broker State Store.
    key string
    The key of the dataset.
    description string
    A user provided optional description of the dataset.
    expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs Sequence[str]
    List of fields for enriching from the Broker State Store.
    key str
    The key of the dataset.
    description str
    A user provided optional description of the dataset.
    expression str
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schema_ref str
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs List<String>
    List of fields for enriching from the Broker State Store.
    key String
    The key of the dataset.
    description String
    A user provided optional description of the dataset.
    expression String
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef String
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.

    DataFlowBuiltInTransformationDatasetResponse, DataFlowBuiltInTransformationDatasetResponseArgs

    Inputs List<string>
    List of fields for enriching from the Broker State Store.
    Key string
    The key of the dataset.
    Description string
    A user provided optional description of the dataset.
    Expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    SchemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    Inputs []string
    List of fields for enriching from the Broker State Store.
    Key string
    The key of the dataset.
    Description string
    A user provided optional description of the dataset.
    Expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    SchemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs List<String>
    List of fields for enriching from the Broker State Store.
    key String
    The key of the dataset.
    description String
    A user provided optional description of the dataset.
    expression String
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef String
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs string[]
    List of fields for enriching from the Broker State Store.
    key string
    The key of the dataset.
    description string
    A user provided optional description of the dataset.
    expression string
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef string
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs Sequence[str]
    List of fields for enriching from the Broker State Store.
    key str
    The key of the dataset.
    description str
    A user provided optional description of the dataset.
    expression str
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schema_ref str
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
    inputs List<String>
    List of fields for enriching from the Broker State Store.
    key String
    The key of the dataset.
    description String
    A user provided optional description of the dataset.
    expression String
    Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    schemaRef String
    The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.

    DataFlowBuiltInTransformationFilter, DataFlowBuiltInTransformationFilterArgs

    Expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    Inputs List<string>
    List of fields for filtering in JSON path expression.
    Description string
    A user provided optional description of the filter.
    Type string | Pulumi.AzureNative.IoTOperations.FilterType
    The type of dataflow operation.
    Expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    Inputs []string
    List of fields for filtering in JSON path expression.
    Description string
    A user provided optional description of the filter.
    Type string | FilterType
    The type of dataflow operation.
    expression String
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs List<String>
    List of fields for filtering in JSON path expression.
    description String
    A user provided optional description of the filter.
    type String | FilterType
    The type of dataflow operation.
    expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs string[]
    List of fields for filtering in JSON path expression.
    description string
    A user provided optional description of the filter.
    type string | FilterType
    The type of dataflow operation.
    expression str
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs Sequence[str]
    List of fields for filtering in JSON path expression.
    description str
    A user provided optional description of the filter.
    type str | FilterType
    The type of dataflow operation.
    expression String
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs List<String>
    List of fields for filtering in JSON path expression.
    description String
    A user provided optional description of the filter.
    type String | "Filter"
    The type of dataflow operation.

    DataFlowBuiltInTransformationFilterResponse, DataFlowBuiltInTransformationFilterResponseArgs

    Expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    Inputs List<string>
    List of fields for filtering in JSON path expression.
    Description string
    A user provided optional description of the filter.
    Type string
    The type of dataflow operation.
    Expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    Inputs []string
    List of fields for filtering in JSON path expression.
    Description string
    A user provided optional description of the filter.
    Type string
    The type of dataflow operation.
    expression String
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs List<String>
    List of fields for filtering in JSON path expression.
    description String
    A user provided optional description of the filter.
    type String
    The type of dataflow operation.
    expression string
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs string[]
    List of fields for filtering in JSON path expression.
    description string
    A user provided optional description of the filter.
    type string
    The type of dataflow operation.
    expression str
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs Sequence[str]
    List of fields for filtering in JSON path expression.
    description str
    A user provided optional description of the filter.
    type str
    The type of dataflow operation.
    expression String
    Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
    inputs List<String>
    List of fields for filtering in JSON path expression.
    description String
    A user provided optional description of the filter.
    type String
    The type of dataflow operation.

    DataFlowBuiltInTransformationMap, DataFlowBuiltInTransformationMapArgs

    Inputs List<string>
    List of fields for mapping in JSON path expression.
    Output string
    Where and how the input fields to be organized in the output record.
    Description string
    A user provided optional description of the mapping function.
    Expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    Type string | Pulumi.AzureNative.IoTOperations.DataFlowMappingType
    Type of transformation.
    Inputs []string
    List of fields for mapping in JSON path expression.
    Output string
    Where and how the input fields to be organized in the output record.
    Description string
    A user provided optional description of the mapping function.
    Expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    Type string | DataFlowMappingType
    Type of transformation.
    inputs List<String>
    List of fields for mapping in JSON path expression.
    output String
    Where and how the input fields to be organized in the output record.
    description String
    A user provided optional description of the mapping function.
    expression String
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type String | DataFlowMappingType
    Type of transformation.
    inputs string[]
    List of fields for mapping in JSON path expression.
    output string
    Where and how the input fields to be organized in the output record.
    description string
    A user provided optional description of the mapping function.
    expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type string | DataFlowMappingType
    Type of transformation.
    inputs Sequence[str]
    List of fields for mapping in JSON path expression.
    output str
    Where and how the input fields to be organized in the output record.
    description str
    A user provided optional description of the mapping function.
    expression str
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type str | DataFlowMappingType
    Type of transformation.
    inputs List<String>
    List of fields for mapping in JSON path expression.
    output String
    Where and how the input fields to be organized in the output record.
    description String
    A user provided optional description of the mapping function.
    expression String
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type String | "NewProperties" | "Rename" | "Compute" | "PassThrough" | "BuiltInFunction"
    Type of transformation.

    DataFlowBuiltInTransformationMapResponse, DataFlowBuiltInTransformationMapResponseArgs

    Inputs List<string>
    List of fields for mapping in JSON path expression.
    Output string
    Where and how the input fields to be organized in the output record.
    Description string
    A user provided optional description of the mapping function.
    Expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    Type string
    Type of transformation.
    Inputs []string
    List of fields for mapping in JSON path expression.
    Output string
    Where and how the input fields to be organized in the output record.
    Description string
    A user provided optional description of the mapping function.
    Expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    Type string
    Type of transformation.
    inputs List<String>
    List of fields for mapping in JSON path expression.
    output String
    Where and how the input fields to be organized in the output record.
    description String
    A user provided optional description of the mapping function.
    expression String
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type String
    Type of transformation.
    inputs string[]
    List of fields for mapping in JSON path expression.
    output string
    Where and how the input fields to be organized in the output record.
    description string
    A user provided optional description of the mapping function.
    expression string
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type string
    Type of transformation.
    inputs Sequence[str]
    List of fields for mapping in JSON path expression.
    output str
    Where and how the input fields to be organized in the output record.
    description str
    A user provided optional description of the mapping function.
    expression str
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type str
    Type of transformation.
    inputs List<String>
    List of fields for mapping in JSON path expression.
    output String
    Where and how the input fields to be organized in the output record.
    description String
    A user provided optional description of the mapping function.
    expression String
    Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
    type String
    Type of transformation.

    DataFlowBuiltInTransformationResponse, DataFlowBuiltInTransformationResponseArgs

    Datasets List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationDatasetResponse>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    Filter List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationFilterResponse>
    Filters input record or datapoints based on condition.
    Map List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformationMapResponse>
    Maps input to output message.
    SchemaRef string
    Reference to the schema that describes the output of the transformation.
    SerializationFormat string
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    Datasets []DataFlowBuiltInTransformationDatasetResponse
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    Filter []DataFlowBuiltInTransformationFilterResponse
    Filters input record or datapoints based on condition.
    Map []DataFlowBuiltInTransformationMapResponse
    Maps input to output message.
    SchemaRef string
    Reference to the schema that describes the output of the transformation.
    SerializationFormat string
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets List<DataFlowBuiltInTransformationDatasetResponse>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter List<DataFlowBuiltInTransformationFilterResponse>
    Filters input record or datapoints based on condition.
    map List<DataFlowBuiltInTransformationMapResponse>
    Maps input to output message.
    schemaRef String
    Reference to the schema that describes the output of the transformation.
    serializationFormat String
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets DataFlowBuiltInTransformationDatasetResponse[]
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter DataFlowBuiltInTransformationFilterResponse[]
    Filters input record or datapoints based on condition.
    map DataFlowBuiltInTransformationMapResponse[]
    Maps input to output message.
    schemaRef string
    Reference to the schema that describes the output of the transformation.
    serializationFormat string
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets Sequence[DataFlowBuiltInTransformationDatasetResponse]
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter Sequence[DataFlowBuiltInTransformationFilterResponse]
    Filters input record or datapoints based on condition.
    map Sequence[DataFlowBuiltInTransformationMapResponse]
    Maps input to output message.
    schema_ref str
    Reference to the schema that describes the output of the transformation.
    serialization_format str
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
    datasets List<Property Map>
    Enrich data from Broker State Store. Dataset references a key in Broker State Store.
    filter List<Property Map>
    Filters input record or datapoints based on condition.
    map List<Property Map>
    Maps input to output message.
    schemaRef String
    Reference to the schema that describes the output of the transformation.
    serializationFormat String
    Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json

    DataFlowDestinationOperation, DataFlowDestinationOperationArgs

    DataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    EndpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    DataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    EndpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination String
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef String
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    data_destination str
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpoint_ref str
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination String
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef String
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.

    DataFlowDestinationOperationResponse, DataFlowDestinationOperationResponseArgs

    DataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    EndpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    DataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    EndpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination String
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef String
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination string
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef string
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    data_destination str
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpoint_ref str
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
    dataDestination String
    Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
    endpointRef String
    Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.

    DataFlowMappingType, DataFlowMappingTypeArgs

    NewProperties
    NewPropertiesNew Properties type
    Rename
    RenameRename type
    Compute
    ComputeCompute type
    PassThrough
    PassThroughPass-through type
    BuiltInFunction
    BuiltInFunctionBuilt in function type
    DataFlowMappingTypeNewProperties
    NewPropertiesNew Properties type
    DataFlowMappingTypeRename
    RenameRename type
    DataFlowMappingTypeCompute
    ComputeCompute type
    DataFlowMappingTypePassThrough
    PassThroughPass-through type
    DataFlowMappingTypeBuiltInFunction
    BuiltInFunctionBuilt in function type
    NewProperties
    NewPropertiesNew Properties type
    Rename
    RenameRename type
    Compute
    ComputeCompute type
    PassThrough
    PassThroughPass-through type
    BuiltInFunction
    BuiltInFunctionBuilt in function type
    NewProperties
    NewPropertiesNew Properties type
    Rename
    RenameRename type
    Compute
    ComputeCompute type
    PassThrough
    PassThroughPass-through type
    BuiltInFunction
    BuiltInFunctionBuilt in function type
    NEW_PROPERTIES
    NewPropertiesNew Properties type
    RENAME
    RenameRename type
    COMPUTE
    ComputeCompute type
    PASS_THROUGH
    PassThroughPass-through type
    BUILT_IN_FUNCTION
    BuiltInFunctionBuilt in function type
    "NewProperties"
    NewPropertiesNew Properties type
    "Rename"
    RenameRename type
    "Compute"
    ComputeCompute type
    "PassThrough"
    PassThroughPass-through type
    "BuiltInFunction"
    BuiltInFunctionBuilt in function type

    DataFlowOperation, DataFlowOperationArgs

    DestinationSettings DataFlowDestinationOperation
    Destination configuration.
    OperationType string | OperationType
    Type of operation.
    SourceSettings DataFlowSourceOperation
    Source configuration.
    BuiltInTransformationSettings DataFlowBuiltInTransformation
    Transformation configuration.
    Name string
    Optional user provided name of the transformation.
    destinationSettings DataFlowDestinationOperation
    Destination configuration.
    operationType String | OperationType
    Type of operation.
    sourceSettings DataFlowSourceOperation
    Source configuration.
    builtInTransformationSettings DataFlowBuiltInTransformation
    Transformation configuration.
    name String
    Optional user provided name of the transformation.
    destinationSettings DataFlowDestinationOperation
    Destination configuration.
    operationType string | OperationType
    Type of operation.
    sourceSettings DataFlowSourceOperation
    Source configuration.
    builtInTransformationSettings DataFlowBuiltInTransformation
    Transformation configuration.
    name string
    Optional user provided name of the transformation.
    destination_settings DataFlowDestinationOperation
    Destination configuration.
    operation_type str | OperationType
    Type of operation.
    source_settings DataFlowSourceOperation
    Source configuration.
    built_in_transformation_settings DataFlowBuiltInTransformation
    Transformation configuration.
    name str
    Optional user provided name of the transformation.
    destinationSettings Property Map
    Destination configuration.
    operationType String | "Source" | "Destination" | "BuiltInTransformation"
    Type of operation.
    sourceSettings Property Map
    Source configuration.
    builtInTransformationSettings Property Map
    Transformation configuration.
    name String
    Optional user provided name of the transformation.

    DataFlowOperationResponse, DataFlowOperationResponseArgs

    DestinationSettings DataFlowDestinationOperationResponse
    Destination configuration.
    OperationType string
    Type of operation.
    SourceSettings DataFlowSourceOperationResponse
    Source configuration.
    BuiltInTransformationSettings DataFlowBuiltInTransformationResponse
    Transformation configuration.
    Name string
    Optional user provided name of the transformation.
    destinationSettings DataFlowDestinationOperationResponse
    Destination configuration.
    operationType String
    Type of operation.
    sourceSettings DataFlowSourceOperationResponse
    Source configuration.
    builtInTransformationSettings DataFlowBuiltInTransformationResponse
    Transformation configuration.
    name String
    Optional user provided name of the transformation.
    destinationSettings DataFlowDestinationOperationResponse
    Destination configuration.
    operationType string
    Type of operation.
    sourceSettings DataFlowSourceOperationResponse
    Source configuration.
    builtInTransformationSettings DataFlowBuiltInTransformationResponse
    Transformation configuration.
    name string
    Optional user provided name of the transformation.
    destination_settings DataFlowDestinationOperationResponse
    Destination configuration.
    operation_type str
    Type of operation.
    source_settings DataFlowSourceOperationResponse
    Source configuration.
    built_in_transformation_settings DataFlowBuiltInTransformationResponse
    Transformation configuration.
    name str
    Optional user provided name of the transformation.
    destinationSettings Property Map
    Destination configuration.
    operationType String
    Type of operation.
    sourceSettings Property Map
    Source configuration.
    builtInTransformationSettings Property Map
    Transformation configuration.
    name String
    Optional user provided name of the transformation.

    DataFlowProperties, DataFlowPropertiesArgs

    Operations List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowOperation>
    List of operations including source and destination references as well as transformation.
    ProfileRef string
    Reference to the DataflowProfile CR.
    Mode string | Pulumi.AzureNative.IoTOperations.OperationalMode
    Mode for DataFlow. Optional; defaults to Enabled.
    Operations []DataFlowOperation
    List of operations including source and destination references as well as transformation.
    ProfileRef string
    Reference to the DataflowProfile CR.
    Mode string | OperationalMode
    Mode for DataFlow. Optional; defaults to Enabled.
    operations List<DataFlowOperation>
    List of operations including source and destination references as well as transformation.
    profileRef String
    Reference to the DataflowProfile CR.
    mode String | OperationalMode
    Mode for DataFlow. Optional; defaults to Enabled.
    operations DataFlowOperation[]
    List of operations including source and destination references as well as transformation.
    profileRef string
    Reference to the DataflowProfile CR.
    mode string | OperationalMode
    Mode for DataFlow. Optional; defaults to Enabled.
    operations Sequence[DataFlowOperation]
    List of operations including source and destination references as well as transformation.
    profile_ref str
    Reference to the DataflowProfile CR.
    mode str | OperationalMode
    Mode for DataFlow. Optional; defaults to Enabled.
    operations List<Property Map>
    List of operations including source and destination references as well as transformation.
    profileRef String
    Reference to the DataflowProfile CR.
    mode String | "Enabled" | "Disabled"
    Mode for DataFlow. Optional; defaults to Enabled.

    DataFlowPropertiesResponse, DataFlowPropertiesResponseArgs

    Operations List<Pulumi.AzureNative.IoTOperations.Inputs.DataFlowOperationResponse>
    List of operations including source and destination references as well as transformation.
    ProfileRef string
    Reference to the DataflowProfile CR.
    ProvisioningState string
    The status of the last operation.
    Mode string
    Mode for DataFlow. Optional; defaults to Enabled.
    Operations []DataFlowOperationResponse
    List of operations including source and destination references as well as transformation.
    ProfileRef string
    Reference to the DataflowProfile CR.
    ProvisioningState string
    The status of the last operation.
    Mode string
    Mode for DataFlow. Optional; defaults to Enabled.
    operations List<DataFlowOperationResponse>
    List of operations including source and destination references as well as transformation.
    profileRef String
    Reference to the DataflowProfile CR.
    provisioningState String
    The status of the last operation.
    mode String
    Mode for DataFlow. Optional; defaults to Enabled.
    operations DataFlowOperationResponse[]
    List of operations including source and destination references as well as transformation.
    profileRef string
    Reference to the DataflowProfile CR.
    provisioningState string
    The status of the last operation.
    mode string
    Mode for DataFlow. Optional; defaults to Enabled.
    operations Sequence[DataFlowOperationResponse]
    List of operations including source and destination references as well as transformation.
    profile_ref str
    Reference to the DataflowProfile CR.
    provisioning_state str
    The status of the last operation.
    mode str
    Mode for DataFlow. Optional; defaults to Enabled.
    operations List<Property Map>
    List of operations including source and destination references as well as transformation.
    profileRef String
    Reference to the DataflowProfile CR.
    provisioningState String
    The status of the last operation.
    mode String
    Mode for DataFlow. Optional; defaults to Enabled.

    DataFlowSourceOperation, DataFlowSourceOperationArgs

    DataSources List<string>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    EndpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    AssetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    SchemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    SerializationFormat string | Pulumi.AzureNative.IoTOperations.SourceSerializationFormat
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    DataSources []string
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    EndpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    AssetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    SchemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    SerializationFormat string | SourceSerializationFormat
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources List<String>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef String
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef String
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef String
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat String | SourceSerializationFormat
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources string[]
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat string | SourceSerializationFormat
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    data_sources Sequence[str]
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpoint_ref str
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    asset_ref str
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schema_ref str
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serialization_format str | SourceSerializationFormat
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources List<String>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef String
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef String
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef String
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat String | "Json"
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.

    DataFlowSourceOperationResponse, DataFlowSourceOperationResponseArgs

    DataSources List<string>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    EndpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    AssetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    SchemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    SerializationFormat string
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    DataSources []string
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    EndpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    AssetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    SchemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    SerializationFormat string
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources List<String>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef String
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef String
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef String
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat String
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources string[]
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef string
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef string
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef string
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat string
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    data_sources Sequence[str]
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpoint_ref str
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    asset_ref str
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schema_ref str
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serialization_format str
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.
    dataSources List<String>
    List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
    endpointRef String
    Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
    assetRef String
    Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
    schemaRef String
    Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
    serializationFormat String
    Content is a JSON Schema. Allowed: JSON Schema/draft-7.

    ExtendedLocation, ExtendedLocationArgs

    Name string
    The name of the extended location.
    Type string | Pulumi.AzureNative.IoTOperations.ExtendedLocationType
    Type of ExtendedLocation.
    Name string
    The name of the extended location.
    Type string | ExtendedLocationType
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String | ExtendedLocationType
    Type of ExtendedLocation.
    name string
    The name of the extended location.
    type string | ExtendedLocationType
    Type of ExtendedLocation.
    name str
    The name of the extended location.
    type str | ExtendedLocationType
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String | "CustomLocation"
    Type of ExtendedLocation.

    ExtendedLocationResponse, ExtendedLocationResponseArgs

    Name string
    The name of the extended location.
    Type string
    Type of ExtendedLocation.
    Name string
    The name of the extended location.
    Type string
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String
    Type of ExtendedLocation.
    name string
    The name of the extended location.
    type string
    Type of ExtendedLocation.
    name str
    The name of the extended location.
    type str
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String
    Type of ExtendedLocation.

    ExtendedLocationType, ExtendedLocationTypeArgs

    CustomLocation
    CustomLocationCustomLocation type
    ExtendedLocationTypeCustomLocation
    CustomLocationCustomLocation type
    CustomLocation
    CustomLocationCustomLocation type
    CustomLocation
    CustomLocationCustomLocation type
    CUSTOM_LOCATION
    CustomLocationCustomLocation type
    "CustomLocation"
    CustomLocationCustomLocation type

    FilterType, FilterTypeArgs

    Filter
    FilterFilter type
    FilterTypeFilter
    FilterFilter type
    Filter
    FilterFilter type
    Filter
    FilterFilter type
    FILTER
    FilterFilter type
    "Filter"
    FilterFilter type

    OperationType, OperationTypeArgs

    Source
    SourceDataFlow Source Operation
    Destination
    DestinationDataFlow Destination Operation
    BuiltInTransformation
    BuiltInTransformationDataFlow BuiltIn Transformation Operation
    OperationTypeSource
    SourceDataFlow Source Operation
    OperationTypeDestination
    DestinationDataFlow Destination Operation
    OperationTypeBuiltInTransformation
    BuiltInTransformationDataFlow BuiltIn Transformation Operation
    Source
    SourceDataFlow Source Operation
    Destination
    DestinationDataFlow Destination Operation
    BuiltInTransformation
    BuiltInTransformationDataFlow BuiltIn Transformation Operation
    Source
    SourceDataFlow Source Operation
    Destination
    DestinationDataFlow Destination Operation
    BuiltInTransformation
    BuiltInTransformationDataFlow BuiltIn Transformation Operation
    SOURCE
    SourceDataFlow Source Operation
    DESTINATION
    DestinationDataFlow Destination Operation
    BUILT_IN_TRANSFORMATION
    BuiltInTransformationDataFlow BuiltIn Transformation Operation
    "Source"
    SourceDataFlow Source Operation
    "Destination"
    DestinationDataFlow Destination Operation
    "BuiltInTransformation"
    BuiltInTransformationDataFlow BuiltIn Transformation Operation

    OperationalMode, OperationalModeArgs

    Enabled
    EnabledEnabled is equivalent to True
    Disabled
    DisabledDisabled is equivalent to False.
    OperationalModeEnabled
    EnabledEnabled is equivalent to True
    OperationalModeDisabled
    DisabledDisabled is equivalent to False.
    Enabled
    EnabledEnabled is equivalent to True
    Disabled
    DisabledDisabled is equivalent to False.
    Enabled
    EnabledEnabled is equivalent to True
    Disabled
    DisabledDisabled is equivalent to False.
    ENABLED
    EnabledEnabled is equivalent to True
    DISABLED
    DisabledDisabled is equivalent to False.
    "Enabled"
    EnabledEnabled is equivalent to True
    "Disabled"
    DisabledDisabled is equivalent to False.

    SourceSerializationFormat, SourceSerializationFormatArgs

    Json
    JsonJSON Format
    SourceSerializationFormatJson
    JsonJSON Format
    Json
    JsonJSON Format
    Json
    JsonJSON Format
    JSON
    JsonJSON Format
    "Json"
    JsonJSON Format

    SystemDataResponse, SystemDataResponseArgs

    CreatedAt string
    The timestamp of resource creation (UTC).
    CreatedBy string
    The identity that created the resource.
    CreatedByType string
    The type of identity that created the resource.
    LastModifiedAt string
    The timestamp of resource last modification (UTC)
    LastModifiedBy string
    The identity that last modified the resource.
    LastModifiedByType string
    The type of identity that last modified the resource.
    CreatedAt string
    The timestamp of resource creation (UTC).
    CreatedBy string
    The identity that created the resource.
    CreatedByType string
    The type of identity that created the resource.
    LastModifiedAt string
    The timestamp of resource last modification (UTC)
    LastModifiedBy string
    The identity that last modified the resource.
    LastModifiedByType string
    The type of identity that last modified the resource.
    createdAt String
    The timestamp of resource creation (UTC).
    createdBy String
    The identity that created the resource.
    createdByType String
    The type of identity that created the resource.
    lastModifiedAt String
    The timestamp of resource last modification (UTC)
    lastModifiedBy String
    The identity that last modified the resource.
    lastModifiedByType String
    The type of identity that last modified the resource.
    createdAt string
    The timestamp of resource creation (UTC).
    createdBy string
    The identity that created the resource.
    createdByType string
    The type of identity that created the resource.
    lastModifiedAt string
    The timestamp of resource last modification (UTC)
    lastModifiedBy string
    The identity that last modified the resource.
    lastModifiedByType string
    The type of identity that last modified the resource.
    created_at str
    The timestamp of resource creation (UTC).
    created_by str
    The identity that created the resource.
    created_by_type str
    The type of identity that created the resource.
    last_modified_at str
    The timestamp of resource last modification (UTC)
    last_modified_by str
    The identity that last modified the resource.
    last_modified_by_type str
    The type of identity that last modified the resource.
    createdAt String
    The timestamp of resource creation (UTC).
    createdBy String
    The identity that created the resource.
    createdByType String
    The type of identity that created the resource.
    lastModifiedAt String
    The timestamp of resource last modification (UTC)
    lastModifiedBy String
    The identity that last modified the resource.
    lastModifiedByType String
    The type of identity that last modified the resource.

    TransformationSerializationFormat, TransformationSerializationFormatArgs

    Delta
    DeltaDelta Format
    Json
    JsonJSON Format
    Parquet
    ParquetParquet Format
    TransformationSerializationFormatDelta
    DeltaDelta Format
    TransformationSerializationFormatJson
    JsonJSON Format
    TransformationSerializationFormatParquet
    ParquetParquet Format
    Delta
    DeltaDelta Format
    Json
    JsonJSON Format
    Parquet
    ParquetParquet Format
    Delta
    DeltaDelta Format
    Json
    JsonJSON Format
    Parquet
    ParquetParquet Format
    DELTA
    DeltaDelta Format
    JSON
    JsonJSON Format
    PARQUET
    ParquetParquet Format
    "Delta"
    DeltaDelta Format
    "Json"
    JsonJSON Format
    "Parquet"
    ParquetParquet Format

    Import

    An existing resource can be imported using its type token, name, and identifier, e.g.

    $ pulumi import azure-native:iotoperations:DataFlow gyhhonqupjblolottsc /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/dataflowProfiles/{dataflowProfileName}/dataflows/{dataflowName} 
    

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

    Package Details

    Repository
    Azure Native pulumi/pulumi-azure-native
    License
    Apache-2.0
    azure-native logo
    This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
    Azure Native v2.77.0 published on Thursday, Dec 12, 2024 by Pulumi