Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Azure Native v2
  3. API Docs
  4. iotoperations
  5. DataFlow
These are the docs for Azure Native v2. We recommenend using the latest version, Azure Native v3.
Azure Native v2 v2.90.0 published on Thursday, Mar 27, 2025 by Pulumi
pulumi/pulumi-azure-native

azure-native-v2.iotoperations.DataFlow

Explore with Pulumi AI

These are the docs for Azure Native v2. We recommenend using the latest version, Azure Native v3.
Azure Native v2 v2.90.0 published on Thursday, Mar 27, 2025 by Pulumi
pulumi/pulumi-azure-native

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",
    });

});
Copy
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
	})
}
Copy
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());

    }
}
Copy
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",
});
Copy
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")
Copy
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
Copy

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 This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name This property is required. str
The unique name of the resource.
args This property is required. 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 This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
name This property is required. String
The unique name of the resource.
args This property is required. 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 = 
    {
        { "name", "string" },
        { "type", "string" },
    },
    InstanceName = "string",
    ResourceGroupName = "string",
    DataflowName = "string",
    Properties = 
    {
        { "operations", new[]
        {
            
            {
                { "destinationSettings", 
                {
                    { "dataDestination", "string" },
                    { "endpointRef", "string" },
                } },
                { "operationType", "string" },
                { "sourceSettings", 
                {
                    { "dataSources", new[]
                    {
                        "string",
                    } },
                    { "endpointRef", "string" },
                    { "assetRef", "string" },
                    { "schemaRef", "string" },
                    { "serializationFormat", "string" },
                } },
                { "builtInTransformationSettings", 
                {
                    { "datasets", new[]
                    {
                        
                        {
                            { "inputs", new[]
                            {
                                "string",
                            } },
                            { "key", "string" },
                            { "description", "string" },
                            { "expression", "string" },
                            { "schemaRef", "string" },
                        },
                    } },
                    { "filter", new[]
                    {
                        
                        {
                            { "expression", "string" },
                            { "inputs", new[]
                            {
                                "string",
                            } },
                            { "description", "string" },
                            { "type", "string" },
                        },
                    } },
                    { "map", new[]
                    {
                        
                        {
                            { "inputs", new[]
                            {
                                "string",
                            } },
                            { "output", "string" },
                            { "description", "string" },
                            { "expression", "string" },
                            { "type", "string" },
                        },
                    } },
                    { "schemaRef", "string" },
                    { "serializationFormat", "string" },
                } },
                { "name", "string" },
            },
        } },
        { "profileRef", "string" },
        { "mode", "string" },
    },
});
Copy
example, err := iotoperations.NewDataFlow(ctx, "azure-nativeDataFlowResource", &iotoperations.DataFlowArgs{
	DataflowProfileName: "string",
	ExtendedLocation: map[string]interface{}{
		"name": "string",
		"type": "string",
	},
	InstanceName:      "string",
	ResourceGroupName: "string",
	DataflowName:      "string",
	Properties: map[string]interface{}{
		"operations": []map[string]interface{}{
			map[string]interface{}{
				"destinationSettings": map[string]interface{}{
					"dataDestination": "string",
					"endpointRef":     "string",
				},
				"operationType": "string",
				"sourceSettings": map[string]interface{}{
					"dataSources": []string{
						"string",
					},
					"endpointRef":         "string",
					"assetRef":            "string",
					"schemaRef":           "string",
					"serializationFormat": "string",
				},
				"builtInTransformationSettings": map[string]interface{}{
					"datasets": []map[string]interface{}{
						map[string]interface{}{
							"inputs": []string{
								"string",
							},
							"key":         "string",
							"description": "string",
							"expression":  "string",
							"schemaRef":   "string",
						},
					},
					"filter": []map[string]interface{}{
						map[string]interface{}{
							"expression": "string",
							"inputs": []string{
								"string",
							},
							"description": "string",
							"type":        "string",
						},
					},
					"map": []map[string]interface{}{
						map[string]interface{}{
							"inputs": []string{
								"string",
							},
							"output":      "string",
							"description": "string",
							"expression":  "string",
							"type":        "string",
						},
					},
					"schemaRef":           "string",
					"serializationFormat": "string",
				},
				"name": "string",
			},
		},
		"profileRef": "string",
		"mode":       "string",
	},
})
Copy
var azure_nativeDataFlowResource = new DataFlow("azure-nativeDataFlowResource", DataFlowArgs.builder()
    .dataflowProfileName("string")
    .extendedLocation(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
    .instanceName("string")
    .resourceGroupName("string")
    .dataflowName("string")
    .properties(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
    .build());
Copy
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: [{
            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,
    })
Copy
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",
    },
});
Copy
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
Copy

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
This property is required.
Changes to this property will trigger replacement.
string
Name of Instance dataflowProfile resource
ExtendedLocation
This property is required.
Changes to this property will trigger replacement.
Pulumi.AzureNative.IoTOperations.Inputs.ExtendedLocation
Edge location of the resource.
InstanceName
This property is required.
Changes to this property will trigger replacement.
string
Name of instance.
ResourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The name of the resource group. The name is case insensitive.
DataflowName Changes to this property will trigger replacement. string
Name of Instance dataflowProfile dataflow resource
Properties Pulumi.AzureNative.IoTOperations.Inputs.DataFlowProperties
The resource-specific properties for this resource.
DataflowProfileName
This property is required.
Changes to this property will trigger replacement.
string
Name of Instance dataflowProfile resource
ExtendedLocation
This property is required.
Changes to this property will trigger replacement.
ExtendedLocationArgs
Edge location of the resource.
InstanceName
This property is required.
Changes to this property will trigger replacement.
string
Name of instance.
ResourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The name of the resource group. The name is case insensitive.
DataflowName Changes to this property will trigger replacement. string
Name of Instance dataflowProfile dataflow resource
Properties DataFlowPropertiesArgs
The resource-specific properties for this resource.
dataflowProfileName
This property is required.
Changes to this property will trigger replacement.
String
Name of Instance dataflowProfile resource
extendedLocation
This property is required.
Changes to this property will trigger replacement.
ExtendedLocation
Edge location of the resource.
instanceName
This property is required.
Changes to this property will trigger replacement.
String
Name of instance.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
String
The name of the resource group. The name is case insensitive.
dataflowName Changes to this property will trigger replacement. String
Name of Instance dataflowProfile dataflow resource
properties DataFlowProperties
The resource-specific properties for this resource.
dataflowProfileName
This property is required.
Changes to this property will trigger replacement.
string
Name of Instance dataflowProfile resource
extendedLocation
This property is required.
Changes to this property will trigger replacement.
ExtendedLocation
Edge location of the resource.
instanceName
This property is required.
Changes to this property will trigger replacement.
string
Name of instance.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The name of the resource group. The name is case insensitive.
dataflowName Changes to this property will trigger replacement. string
Name of Instance dataflowProfile dataflow resource
properties DataFlowProperties
The resource-specific properties for this resource.
dataflow_profile_name
This property is required.
Changes to this property will trigger replacement.
str
Name of Instance dataflowProfile resource
extended_location
This property is required.
Changes to this property will trigger replacement.
ExtendedLocationArgs
Edge location of the resource.
instance_name
This property is required.
Changes to this property will trigger replacement.
str
Name of instance.
resource_group_name
This property is required.
Changes to this property will trigger replacement.
str
The name of the resource group. The name is case insensitive.
dataflow_name Changes to this property will trigger replacement. str
Name of Instance dataflowProfile dataflow resource
properties DataFlowPropertiesArgs
The resource-specific properties for this resource.
dataflowProfileName
This property is required.
Changes to this property will trigger replacement.
String
Name of Instance dataflowProfile resource
extendedLocation
This property is required.
Changes to this property will trigger replacement.
Property Map
Edge location of the resource.
instanceName
This property is required.
Changes to this property will trigger replacement.
String
Name of instance.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
String
The name of the resource group. The name is case insensitive.
dataflowName Changes to this property will trigger replacement. 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 This property is required. List<string>
List of fields for enriching from the Broker State Store.
Key This property is required. 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 This property is required. []string
List of fields for enriching from the Broker State Store.
Key This property is required. 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 This property is required. List<String>
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. string[]
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. Sequence[str]
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. List<String>
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. List<string>
List of fields for enriching from the Broker State Store.
Key This property is required. 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 This property is required. []string
List of fields for enriching from the Broker State Store.
Key This property is required. 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 This property is required. List<String>
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. string[]
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. Sequence[str]
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. List<String>
List of fields for enriching from the Broker State Store.
key This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. []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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. []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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. List<string>
List of fields for mapping in JSON path expression.
Output This property is required. 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 This property is required. []string
List of fields for mapping in JSON path expression.
Output This property is required. 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 This property is required. List<String>
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. string[]
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. Sequence[str]
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. List<String>
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. List<string>
List of fields for mapping in JSON path expression.
Output This property is required. 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 This property is required. []string
List of fields for mapping in JSON path expression.
Output This property is required. 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 This property is required. List<String>
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. string[]
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. Sequence[str]
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. List<String>
List of fields for mapping in JSON path expression.
output This property is required. 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 This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
EndpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
DataDestination This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
EndpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. String
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. String
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
data_destination This property is required. str
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpoint_ref This property is required. str
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. String
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. String
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.

DataFlowDestinationOperationResponse
, DataFlowDestinationOperationResponseArgs

DataDestination This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
EndpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
DataDestination This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
EndpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. String
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. String
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. string
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. string
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
data_destination This property is required. str
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpoint_ref This property is required. str
Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
dataDestination This property is required. String
Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
endpointRef This property is required. 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 This property is required. Pulumi.AzureNative.IoTOperations.Inputs.DataFlowDestinationOperation
Destination configuration.
OperationType This property is required. string | Pulumi.AzureNative.IoTOperations.OperationType
Type of operation.
SourceSettings This property is required. Pulumi.AzureNative.IoTOperations.Inputs.DataFlowSourceOperation
Source configuration.
BuiltInTransformationSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowBuiltInTransformation
Transformation configuration.
Name string
Optional user provided name of the transformation.
DestinationSettings This property is required. DataFlowDestinationOperation
Destination configuration.
OperationType This property is required. string | OperationType
Type of operation.
SourceSettings This property is required. DataFlowSourceOperation
Source configuration.
BuiltInTransformationSettings DataFlowBuiltInTransformation
Transformation configuration.
Name string
Optional user provided name of the transformation.
destinationSettings This property is required. DataFlowDestinationOperation
Destination configuration.
operationType This property is required. String | OperationType
Type of operation.
sourceSettings This property is required. DataFlowSourceOperation
Source configuration.
builtInTransformationSettings DataFlowBuiltInTransformation
Transformation configuration.
name String
Optional user provided name of the transformation.
destinationSettings This property is required. DataFlowDestinationOperation
Destination configuration.
operationType This property is required. string | OperationType
Type of operation.
sourceSettings This property is required. DataFlowSourceOperation
Source configuration.
builtInTransformationSettings DataFlowBuiltInTransformation
Transformation configuration.
name string
Optional user provided name of the transformation.
destination_settings This property is required. DataFlowDestinationOperation
Destination configuration.
operation_type This property is required. str | OperationType
Type of operation.
source_settings This property is required. DataFlowSourceOperation
Source configuration.
built_in_transformation_settings DataFlowBuiltInTransformation
Transformation configuration.
name str
Optional user provided name of the transformation.
destinationSettings This property is required. Property Map
Destination configuration.
operationType This property is required. String | "Source" | "Destination" | "BuiltInTransformation"
Type of operation.
sourceSettings This property is required. Property Map
Source configuration.
builtInTransformationSettings Property Map
Transformation configuration.
name String
Optional user provided name of the transformation.

DataFlowOperationResponse
, DataFlowOperationResponseArgs

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

DataFlowProperties
, DataFlowPropertiesArgs

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

DataFlowPropertiesResponse
, DataFlowPropertiesResponseArgs

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

DataFlowSourceOperation
, DataFlowSourceOperationArgs

DataSources This property is required. List<string>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
EndpointRef This property is required. 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 This property is required. []string
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
EndpointRef This property is required. 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 This property is required. List<String>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. string[]
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. Sequence[str]
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpoint_ref This property is required. 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 This property is required. List<String>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. List<string>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
EndpointRef This property is required. 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 This property is required. []string
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
EndpointRef This property is required. 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 This property is required. List<String>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. string[]
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. Sequence[str]
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpoint_ref This property is required. 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 This property is required. List<String>
List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
endpointRef This property is required. 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 This property is required. string
The name of the extended location.
Type This property is required. string | Pulumi.AzureNative.IoTOperations.ExtendedLocationType
Type of ExtendedLocation.
Name This property is required. string
The name of the extended location.
Type This property is required. string | ExtendedLocationType
Type of ExtendedLocation.
name This property is required. String
The name of the extended location.
type This property is required. String | ExtendedLocationType
Type of ExtendedLocation.
name This property is required. string
The name of the extended location.
type This property is required. string | ExtendedLocationType
Type of ExtendedLocation.
name This property is required. str
The name of the extended location.
type This property is required. str | ExtendedLocationType
Type of ExtendedLocation.
name This property is required. String
The name of the extended location.
type This property is required. String | "CustomLocation"
Type of ExtendedLocation.

ExtendedLocationResponse
, ExtendedLocationResponseArgs

Name This property is required. string
The name of the extended location.
Type This property is required. string
Type of ExtendedLocation.
Name This property is required. string
The name of the extended location.
Type This property is required. string
Type of ExtendedLocation.
name This property is required. String
The name of the extended location.
type This property is required. String
Type of ExtendedLocation.
name This property is required. string
The name of the extended location.
type This property is required. string
Type of ExtendedLocation.
name This property is required. str
The name of the extended location.
type This property is required. str
Type of ExtendedLocation.
name This property is required. String
The name of the extended location.
type This property is required. 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}
Copy

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

Package Details

Repository
azure-native-v2 pulumi/pulumi-azure-native
License
Apache-2.0
These are the docs for Azure Native v2. We recommenend using the latest version, Azure Native v3.
Azure Native v2 v2.90.0 published on Thursday, Mar 27, 2025 by Pulumi
pulumi/pulumi-azure-native