Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Azure Native
  3. API Docs
  4. datafactory
  5. DataFlow
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.4.0 published on Wednesday, May 7, 2025 by Pulumi
pulumi/pulumi-azure-native

azure-native.datafactory.DataFlow

Explore with Pulumi AI

azure-native logo
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.4.0 published on Wednesday, May 7, 2025 by Pulumi
pulumi/pulumi-azure-native

    Data flow resource type.

    Uses Azure REST API version 2018-06-01. In version 2.x of the Azure Native provider, it used API version 2018-06-01.

    Example Usage

    DataFlows_Create

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

return await Deployment.RunAsync(() => 
{
    var dataFlow = new AzureNative.DataFactory.DataFlow("dataFlow", new()
    {
        DataFlowName = "exampleDataFlow",
        FactoryName = "exampleFactoryName",
        Properties = new AzureNative.DataFactory.Inputs.MappingDataFlowArgs
        {
            Description = "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
            ScriptLines = new[]
            {
                "source(output(",
                "PreviousConversionRate as double,",
                "Country as string,",
                "DateTime1 as string,",
                "CurrentConversionRate as double",
                "),",
                "allowSchemaDrift: false,",
                "validateSchema: false) ~> USDCurrency",
                "source(output(",
                "PreviousConversionRate as double,",
                "Country as string,",
                "DateTime1 as string,",
                "CurrentConversionRate as double",
                "),",
                "allowSchemaDrift: true,",
                "validateSchema: false) ~> CADSource",
                "USDCurrency, CADSource union(byName: true)~> Union",
                "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
                "NewCurrencyColumn split(Country == 'USD',",
                "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
                "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
                "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
            },
            Sinks = new[]
            {
                new AzureNative.DataFactory.Inputs.DataFlowSinkArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "USDOutput",
                        Type = "DatasetReference",
                    },
                    Name = "USDSink",
                },
                new AzureNative.DataFactory.Inputs.DataFlowSinkArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CADOutput",
                        Type = "DatasetReference",
                    },
                    Name = "CADSink",
                },
            },
            Sources = new[]
            {
                new AzureNative.DataFactory.Inputs.DataFlowSourceArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CurrencyDatasetUSD",
                        Type = "DatasetReference",
                    },
                    Name = "USDCurrency",
                },
                new AzureNative.DataFactory.Inputs.DataFlowSourceArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CurrencyDatasetCAD",
                        Type = "DatasetReference",
                    },
                    Name = "CADSource",
                },
            },
            Type = "MappingDataFlow",
        },
        ResourceGroupName = "exampleResourceGroup",
    });

});

    package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafactory.NewDataFlow(ctx, "dataFlow", &datafactory.DataFlowArgs{
			DataFlowName: pulumi.String("exampleDataFlow"),
			FactoryName:  pulumi.String("exampleFactoryName"),
			Properties: &datafactory.MappingDataFlowArgs{
				Description: pulumi.String("Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation."),
				ScriptLines: pulumi.StringArray{
					pulumi.String("source(output("),
					pulumi.String("PreviousConversionRate as double,"),
					pulumi.String("Country as string,"),
					pulumi.String("DateTime1 as string,"),
					pulumi.String("CurrentConversionRate as double"),
					pulumi.String("),"),
					pulumi.String("allowSchemaDrift: false,"),
					pulumi.String("validateSchema: false) ~> USDCurrency"),
					pulumi.String("source(output("),
					pulumi.String("PreviousConversionRate as double,"),
					pulumi.String("Country as string,"),
					pulumi.String("DateTime1 as string,"),
					pulumi.String("CurrentConversionRate as double"),
					pulumi.String("),"),
					pulumi.String("allowSchemaDrift: true,"),
					pulumi.String("validateSchema: false) ~> CADSource"),
					pulumi.String("USDCurrency, CADSource union(byName: true)~> Union"),
					pulumi.String("Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn"),
					pulumi.String("NewCurrencyColumn split(Country == 'USD',"),
					pulumi.String("Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)"),
					pulumi.String("ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink"),
					pulumi.String("ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink"),
				},
				Sinks: datafactory.DataFlowSinkArray{
					&datafactory.DataFlowSinkArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("USDOutput"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("USDSink"),
					},
					&datafactory.DataFlowSinkArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CADOutput"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("CADSink"),
					},
				},
				Sources: datafactory.DataFlowSourceArray{
					&datafactory.DataFlowSourceArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CurrencyDatasetUSD"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("USDCurrency"),
					},
					&datafactory.DataFlowSourceArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CurrencyDatasetCAD"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("CADSource"),
					},
				},
				Type: pulumi.String("MappingDataFlow"),
			},
			ResourceGroupName: pulumi.String("exampleResourceGroup"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.datafactory.DataFlow;
import com.pulumi.azurenative.datafactory.DataFlowArgs;
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("exampleDataFlow")
            .factoryName("exampleFactoryName")
            .properties(MappingDataFlowArgs.builder()
                .description("Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.")
                .scriptLines(                
                    "source(output(",
                    "PreviousConversionRate as double,",
                    "Country as string,",
                    "DateTime1 as string,",
                    "CurrentConversionRate as double",
                    "),",
                    "allowSchemaDrift: false,",
                    "validateSchema: false) ~> USDCurrency",
                    "source(output(",
                    "PreviousConversionRate as double,",
                    "Country as string,",
                    "DateTime1 as string,",
                    "CurrentConversionRate as double",
                    "),",
                    "allowSchemaDrift: true,",
                    "validateSchema: false) ~> CADSource",
                    "USDCurrency, CADSource union(byName: true)~> Union",
                    "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
                    "NewCurrencyColumn split(Country == 'USD',",
                    "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
                    "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
                    "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink")
                .sinks(                
                    DataFlowSinkArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("USDOutput")
                            .type("DatasetReference")
                            .build())
                        .name("USDSink")
                        .build(),
                    DataFlowSinkArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CADOutput")
                            .type("DatasetReference")
                            .build())
                        .name("CADSink")
                        .build())
                .sources(                
                    DataFlowSourceArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CurrencyDatasetUSD")
                            .type("DatasetReference")
                            .build())
                        .name("USDCurrency")
                        .build(),
                    DataFlowSourceArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CurrencyDatasetCAD")
                            .type("DatasetReference")
                            .build())
                        .name("CADSource")
                        .build())
                .type("MappingDataFlow")
                .build())
            .resourceGroupName("exampleResourceGroup")
            .build());

    }
}

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

const dataFlow = new azure_native.datafactory.DataFlow("dataFlow", {
    dataFlowName: "exampleDataFlow",
    factoryName: "exampleFactoryName",
    properties: {
        description: "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
        scriptLines: [
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: false,",
            "validateSchema: false) ~> USDCurrency",
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: true,",
            "validateSchema: false) ~> CADSource",
            "USDCurrency, CADSource union(byName: true)~> Union",
            "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
            "NewCurrencyColumn split(Country == 'USD',",
            "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
            "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
            "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
        ],
        sinks: [
            {
                dataset: {
                    referenceName: "USDOutput",
                    type: "DatasetReference",
                },
                name: "USDSink",
            },
            {
                dataset: {
                    referenceName: "CADOutput",
                    type: "DatasetReference",
                },
                name: "CADSink",
            },
        ],
        sources: [
            {
                dataset: {
                    referenceName: "CurrencyDatasetUSD",
                    type: "DatasetReference",
                },
                name: "USDCurrency",
            },
            {
                dataset: {
                    referenceName: "CurrencyDatasetCAD",
                    type: "DatasetReference",
                },
                name: "CADSource",
            },
        ],
        type: "MappingDataFlow",
    },
    resourceGroupName: "exampleResourceGroup",
});

    import pulumi
import pulumi_azure_native as azure_native

data_flow = azure_native.datafactory.DataFlow("dataFlow",
    data_flow_name="exampleDataFlow",
    factory_name="exampleFactoryName",
    properties={
        "description": "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
        "script_lines": [
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: false,",
            "validateSchema: false) ~> USDCurrency",
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: true,",
            "validateSchema: false) ~> CADSource",
            "USDCurrency, CADSource union(byName: true)~> Union",
            "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
            "NewCurrencyColumn split(Country == 'USD',",
            "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
            "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
            "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
        ],
        "sinks": [
            {
                "dataset": {
                    "reference_name": "USDOutput",
                    "type": "DatasetReference",
                },
                "name": "USDSink",
            },
            {
                "dataset": {
                    "reference_name": "CADOutput",
                    "type": "DatasetReference",
                },
                "name": "CADSink",
            },
        ],
        "sources": [
            {
                "dataset": {
                    "reference_name": "CurrencyDatasetUSD",
                    "type": "DatasetReference",
                },
                "name": "USDCurrency",
            },
            {
                "dataset": {
                    "reference_name": "CurrencyDatasetCAD",
                    "type": "DatasetReference",
                },
                "name": "CADSource",
            },
        ],
        "type": "MappingDataFlow",
    },
    resource_group_name="exampleResourceGroup")

    resources:
  dataFlow:
    type: azure-native:datafactory:DataFlow
    properties:
      dataFlowName: exampleDataFlow
      factoryName: exampleFactoryName
      properties:
        description: Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.
        scriptLines:
          - source(output(
          - PreviousConversionRate as double,
          - Country as string,
          - DateTime1 as string,
          - CurrentConversionRate as double
          - ),
          - 'allowSchemaDrift: false,'
          - 'validateSchema: false) ~> USDCurrency'
          - source(output(
          - PreviousConversionRate as double,
          - Country as string,
          - DateTime1 as string,
          - CurrentConversionRate as double
          - ),
          - 'allowSchemaDrift: true,'
          - 'validateSchema: false) ~> CADSource'
          - 'USDCurrency, CADSource union(byName: true)~> Union'
          - Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn
          - NewCurrencyColumn split(Country == 'USD',
          - 'Country == ''CAD'',disjoint: false) ~> ConditionalSplit1@(USD, CAD)'
          - ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink
          - ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink
        sinks:
          - dataset:
              referenceName: USDOutput
              type: DatasetReference
            name: USDSink
          - dataset:
              referenceName: CADOutput
              type: DatasetReference
            name: CADSink
        sources:
          - dataset:
              referenceName: CurrencyDatasetUSD
              type: DatasetReference
            name: USDCurrency
          - dataset:
              referenceName: CurrencyDatasetCAD
              type: DatasetReference
            name: CADSource
        type: MappingDataFlow
      resourceGroupName: exampleResourceGroup

    DataFlows_Update

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

return await Deployment.RunAsync(() => 
{
    var dataFlow = new AzureNative.DataFactory.DataFlow("dataFlow", new()
    {
        DataFlowName = "exampleDataFlow",
        FactoryName = "exampleFactoryName",
        Properties = new AzureNative.DataFactory.Inputs.MappingDataFlowArgs
        {
            Description = "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
            ScriptLines = new[]
            {
                "source(output(",
                "PreviousConversionRate as double,",
                "Country as string,",
                "DateTime1 as string,",
                "CurrentConversionRate as double",
                "),",
                "allowSchemaDrift: false,",
                "validateSchema: false) ~> USDCurrency",
                "source(output(",
                "PreviousConversionRate as double,",
                "Country as string,",
                "DateTime1 as string,",
                "CurrentConversionRate as double",
                "),",
                "allowSchemaDrift: true,",
                "validateSchema: false) ~> CADSource",
                "USDCurrency, CADSource union(byName: true)~> Union",
                "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
                "NewCurrencyColumn split(Country == 'USD',",
                "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
                "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
                "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
            },
            Sinks = new[]
            {
                new AzureNative.DataFactory.Inputs.DataFlowSinkArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "USDOutput",
                        Type = "DatasetReference",
                    },
                    Name = "USDSink",
                },
                new AzureNative.DataFactory.Inputs.DataFlowSinkArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CADOutput",
                        Type = "DatasetReference",
                    },
                    Name = "CADSink",
                },
            },
            Sources = new[]
            {
                new AzureNative.DataFactory.Inputs.DataFlowSourceArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CurrencyDatasetUSD",
                        Type = "DatasetReference",
                    },
                    Name = "USDCurrency",
                },
                new AzureNative.DataFactory.Inputs.DataFlowSourceArgs
                {
                    Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                    {
                        ReferenceName = "CurrencyDatasetCAD",
                        Type = "DatasetReference",
                    },
                    Name = "CADSource",
                },
            },
            Type = "MappingDataFlow",
        },
        ResourceGroupName = "exampleResourceGroup",
    });

});

    package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafactory.NewDataFlow(ctx, "dataFlow", &datafactory.DataFlowArgs{
			DataFlowName: pulumi.String("exampleDataFlow"),
			FactoryName:  pulumi.String("exampleFactoryName"),
			Properties: &datafactory.MappingDataFlowArgs{
				Description: pulumi.String("Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation."),
				ScriptLines: pulumi.StringArray{
					pulumi.String("source(output("),
					pulumi.String("PreviousConversionRate as double,"),
					pulumi.String("Country as string,"),
					pulumi.String("DateTime1 as string,"),
					pulumi.String("CurrentConversionRate as double"),
					pulumi.String("),"),
					pulumi.String("allowSchemaDrift: false,"),
					pulumi.String("validateSchema: false) ~> USDCurrency"),
					pulumi.String("source(output("),
					pulumi.String("PreviousConversionRate as double,"),
					pulumi.String("Country as string,"),
					pulumi.String("DateTime1 as string,"),
					pulumi.String("CurrentConversionRate as double"),
					pulumi.String("),"),
					pulumi.String("allowSchemaDrift: true,"),
					pulumi.String("validateSchema: false) ~> CADSource"),
					pulumi.String("USDCurrency, CADSource union(byName: true)~> Union"),
					pulumi.String("Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn"),
					pulumi.String("NewCurrencyColumn split(Country == 'USD',"),
					pulumi.String("Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)"),
					pulumi.String("ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink"),
					pulumi.String("ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink"),
				},
				Sinks: datafactory.DataFlowSinkArray{
					&datafactory.DataFlowSinkArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("USDOutput"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("USDSink"),
					},
					&datafactory.DataFlowSinkArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CADOutput"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("CADSink"),
					},
				},
				Sources: datafactory.DataFlowSourceArray{
					&datafactory.DataFlowSourceArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CurrencyDatasetUSD"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("USDCurrency"),
					},
					&datafactory.DataFlowSourceArgs{
						Dataset: &datafactory.DatasetReferenceArgs{
							ReferenceName: pulumi.String("CurrencyDatasetCAD"),
							Type:          pulumi.String("DatasetReference"),
						},
						Name: pulumi.String("CADSource"),
					},
				},
				Type: pulumi.String("MappingDataFlow"),
			},
			ResourceGroupName: pulumi.String("exampleResourceGroup"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.datafactory.DataFlow;
import com.pulumi.azurenative.datafactory.DataFlowArgs;
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("exampleDataFlow")
            .factoryName("exampleFactoryName")
            .properties(MappingDataFlowArgs.builder()
                .description("Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.")
                .scriptLines(                
                    "source(output(",
                    "PreviousConversionRate as double,",
                    "Country as string,",
                    "DateTime1 as string,",
                    "CurrentConversionRate as double",
                    "),",
                    "allowSchemaDrift: false,",
                    "validateSchema: false) ~> USDCurrency",
                    "source(output(",
                    "PreviousConversionRate as double,",
                    "Country as string,",
                    "DateTime1 as string,",
                    "CurrentConversionRate as double",
                    "),",
                    "allowSchemaDrift: true,",
                    "validateSchema: false) ~> CADSource",
                    "USDCurrency, CADSource union(byName: true)~> Union",
                    "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
                    "NewCurrencyColumn split(Country == 'USD',",
                    "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
                    "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
                    "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink")
                .sinks(                
                    DataFlowSinkArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("USDOutput")
                            .type("DatasetReference")
                            .build())
                        .name("USDSink")
                        .build(),
                    DataFlowSinkArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CADOutput")
                            .type("DatasetReference")
                            .build())
                        .name("CADSink")
                        .build())
                .sources(                
                    DataFlowSourceArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CurrencyDatasetUSD")
                            .type("DatasetReference")
                            .build())
                        .name("USDCurrency")
                        .build(),
                    DataFlowSourceArgs.builder()
                        .dataset(DatasetReferenceArgs.builder()
                            .referenceName("CurrencyDatasetCAD")
                            .type("DatasetReference")
                            .build())
                        .name("CADSource")
                        .build())
                .type("MappingDataFlow")
                .build())
            .resourceGroupName("exampleResourceGroup")
            .build());

    }
}

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

const dataFlow = new azure_native.datafactory.DataFlow("dataFlow", {
    dataFlowName: "exampleDataFlow",
    factoryName: "exampleFactoryName",
    properties: {
        description: "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
        scriptLines: [
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: false,",
            "validateSchema: false) ~> USDCurrency",
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: true,",
            "validateSchema: false) ~> CADSource",
            "USDCurrency, CADSource union(byName: true)~> Union",
            "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
            "NewCurrencyColumn split(Country == 'USD',",
            "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
            "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
            "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
        ],
        sinks: [
            {
                dataset: {
                    referenceName: "USDOutput",
                    type: "DatasetReference",
                },
                name: "USDSink",
            },
            {
                dataset: {
                    referenceName: "CADOutput",
                    type: "DatasetReference",
                },
                name: "CADSink",
            },
        ],
        sources: [
            {
                dataset: {
                    referenceName: "CurrencyDatasetUSD",
                    type: "DatasetReference",
                },
                name: "USDCurrency",
            },
            {
                dataset: {
                    referenceName: "CurrencyDatasetCAD",
                    type: "DatasetReference",
                },
                name: "CADSource",
            },
        ],
        type: "MappingDataFlow",
    },
    resourceGroupName: "exampleResourceGroup",
});

    import pulumi
import pulumi_azure_native as azure_native

data_flow = azure_native.datafactory.DataFlow("dataFlow",
    data_flow_name="exampleDataFlow",
    factory_name="exampleFactoryName",
    properties={
        "description": "Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.",
        "script_lines": [
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: false,",
            "validateSchema: false) ~> USDCurrency",
            "source(output(",
            "PreviousConversionRate as double,",
            "Country as string,",
            "DateTime1 as string,",
            "CurrentConversionRate as double",
            "),",
            "allowSchemaDrift: true,",
            "validateSchema: false) ~> CADSource",
            "USDCurrency, CADSource union(byName: true)~> Union",
            "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn",
            "NewCurrencyColumn split(Country == 'USD',",
            "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
            "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
            "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink",
        ],
        "sinks": [
            {
                "dataset": {
                    "reference_name": "USDOutput",
                    "type": "DatasetReference",
                },
                "name": "USDSink",
            },
            {
                "dataset": {
                    "reference_name": "CADOutput",
                    "type": "DatasetReference",
                },
                "name": "CADSink",
            },
        ],
        "sources": [
            {
                "dataset": {
                    "reference_name": "CurrencyDatasetUSD",
                    "type": "DatasetReference",
                },
                "name": "USDCurrency",
            },
            {
                "dataset": {
                    "reference_name": "CurrencyDatasetCAD",
                    "type": "DatasetReference",
                },
                "name": "CADSource",
            },
        ],
        "type": "MappingDataFlow",
    },
    resource_group_name="exampleResourceGroup")

    resources:
  dataFlow:
    type: azure-native:datafactory:DataFlow
    properties:
      dataFlowName: exampleDataFlow
      factoryName: exampleFactoryName
      properties:
        description: Sample demo data flow to convert currencies showing usage of union, derive and conditional split transformation.
        scriptLines:
          - source(output(
          - PreviousConversionRate as double,
          - Country as string,
          - DateTime1 as string,
          - CurrentConversionRate as double
          - ),
          - 'allowSchemaDrift: false,'
          - 'validateSchema: false) ~> USDCurrency'
          - source(output(
          - PreviousConversionRate as double,
          - Country as string,
          - DateTime1 as string,
          - CurrentConversionRate as double
          - ),
          - 'allowSchemaDrift: true,'
          - 'validateSchema: false) ~> CADSource'
          - 'USDCurrency, CADSource union(byName: true)~> Union'
          - Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn
          - NewCurrencyColumn split(Country == 'USD',
          - 'Country == ''CAD'',disjoint: false) ~> ConditionalSplit1@(USD, CAD)'
          - ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink
          - ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink
        sinks:
          - dataset:
              referenceName: USDOutput
              type: DatasetReference
            name: USDSink
          - dataset:
              referenceName: CADOutput
              type: DatasetReference
            name: CADSink
        sources:
          - dataset:
              referenceName: CurrencyDatasetUSD
              type: DatasetReference
            name: USDCurrency
          - dataset:
              referenceName: CurrencyDatasetCAD
              type: DatasetReference
            name: CADSource
        type: MappingDataFlow
      resourceGroupName: exampleResourceGroup

    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,
             factory_name: Optional[str] = None,
             properties: Optional[Union[FlowletArgs, MappingDataFlowArgs, WranglingDataFlowArgs]] = None,
             resource_group_name: Optional[str] = None,
             data_flow_name: Optional[str] = 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:datafactory:DataFlow
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    name string
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DataFlowArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

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

    var dataFlowResource = new AzureNative.DataFactory.DataFlow("dataFlowResource", new()
{
    FactoryName = "string",
    Properties = new AzureNative.DataFactory.Inputs.FlowletArgs
    {
        Type = "Flowlet",
        Annotations = new[]
        {
            "any",
        },
        Description = "string",
        Folder = new AzureNative.DataFactory.Inputs.DataFlowFolderArgs
        {
            Name = "string",
        },
        Script = "string",
        ScriptLines = new[]
        {
            "string",
        },
        Sinks = new[]
        {
            new AzureNative.DataFactory.Inputs.DataFlowSinkArgs
            {
                Name = "string",
                Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                Description = "string",
                Flowlet = new AzureNative.DataFactory.Inputs.DataFlowReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    DatasetParameters = "any",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                LinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                RejectedDataLinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                SchemaLinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
            },
        },
        Sources = new[]
        {
            new AzureNative.DataFactory.Inputs.DataFlowSourceArgs
            {
                Name = "string",
                Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                Description = "string",
                Flowlet = new AzureNative.DataFactory.Inputs.DataFlowReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    DatasetParameters = "any",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                LinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                SchemaLinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
            },
        },
        Transformations = new[]
        {
            new AzureNative.DataFactory.Inputs.TransformationArgs
            {
                Name = "string",
                Dataset = new AzureNative.DataFactory.Inputs.DatasetReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                Description = "string",
                Flowlet = new AzureNative.DataFactory.Inputs.DataFlowReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    DatasetParameters = "any",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
                LinkedService = new AzureNative.DataFactory.Inputs.LinkedServiceReferenceArgs
                {
                    ReferenceName = "string",
                    Type = "string",
                    Parameters = 
                    {
                        { "string", "any" },
                    },
                },
            },
        },
    },
    ResourceGroupName = "string",
    DataFlowName = "string",
});

    example, err := datafactory.NewDataFlow(ctx, "dataFlowResource", &datafactory.DataFlowArgs{
	FactoryName: pulumi.String("string"),
	Properties: &datafactory.FlowletArgs{
		Type: pulumi.String("Flowlet"),
		Annotations: pulumi.Array{
			pulumi.Any("any"),
		},
		Description: pulumi.String("string"),
		Folder: &datafactory.DataFlowFolderArgs{
			Name: pulumi.String("string"),
		},
		Script: pulumi.String("string"),
		ScriptLines: pulumi.StringArray{
			pulumi.String("string"),
		},
		Sinks: datafactory.DataFlowSinkArray{
			&datafactory.DataFlowSinkArgs{
				Name: pulumi.String("string"),
				Dataset: &datafactory.DatasetReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				Description: pulumi.String("string"),
				Flowlet: &datafactory.DataFlowReferenceArgs{
					ReferenceName:     pulumi.String("string"),
					Type:              pulumi.String("string"),
					DatasetParameters: pulumi.Any("any"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				LinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				RejectedDataLinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				SchemaLinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
			},
		},
		Sources: datafactory.DataFlowSourceArray{
			&datafactory.DataFlowSourceArgs{
				Name: pulumi.String("string"),
				Dataset: &datafactory.DatasetReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				Description: pulumi.String("string"),
				Flowlet: &datafactory.DataFlowReferenceArgs{
					ReferenceName:     pulumi.String("string"),
					Type:              pulumi.String("string"),
					DatasetParameters: pulumi.Any("any"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				LinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				SchemaLinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
			},
		},
		Transformations: datafactory.TransformationArray{
			&datafactory.TransformationArgs{
				Name: pulumi.String("string"),
				Dataset: &datafactory.DatasetReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				Description: pulumi.String("string"),
				Flowlet: &datafactory.DataFlowReferenceArgs{
					ReferenceName:     pulumi.String("string"),
					Type:              pulumi.String("string"),
					DatasetParameters: pulumi.Any("any"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
				LinkedService: &datafactory.LinkedServiceReferenceArgs{
					ReferenceName: pulumi.String("string"),
					Type:          pulumi.String("string"),
					Parameters: pulumi.Map{
						"string": pulumi.Any("any"),
					},
				},
			},
		},
	},
	ResourceGroupName: pulumi.String("string"),
	DataFlowName:      pulumi.String("string"),
})

    var dataFlowResource = new DataFlow("dataFlowResource", DataFlowArgs.builder()
    .factoryName("string")
    .properties(FlowletArgs.builder()
        .type("Flowlet")
        .annotations("any")
        .description("string")
        .folder(DataFlowFolderArgs.builder()
            .name("string")
            .build())
        .script("string")
        .scriptLines("string")
        .sinks(DataFlowSinkArgs.builder()
            .name("string")
            .dataset(DatasetReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .description("string")
            .flowlet(DataFlowReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .datasetParameters("any")
                .parameters(Map.of("string", "any"))
                .build())
            .linkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .rejectedDataLinkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .schemaLinkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .build())
        .sources(DataFlowSourceArgs.builder()
            .name("string")
            .dataset(DatasetReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .description("string")
            .flowlet(DataFlowReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .datasetParameters("any")
                .parameters(Map.of("string", "any"))
                .build())
            .linkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .schemaLinkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .build())
        .transformations(TransformationArgs.builder()
            .name("string")
            .dataset(DatasetReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .description("string")
            .flowlet(DataFlowReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .datasetParameters("any")
                .parameters(Map.of("string", "any"))
                .build())
            .linkedService(LinkedServiceReferenceArgs.builder()
                .referenceName("string")
                .type("string")
                .parameters(Map.of("string", "any"))
                .build())
            .build())
        .build())
    .resourceGroupName("string")
    .dataFlowName("string")
    .build());

    data_flow_resource = azure_native.datafactory.DataFlow("dataFlowResource",
    factory_name="string",
    properties={
        "type": "Flowlet",
        "annotations": ["any"],
        "description": "string",
        "folder": {
            "name": "string",
        },
        "script": "string",
        "script_lines": ["string"],
        "sinks": [{
            "name": "string",
            "dataset": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "description": "string",
            "flowlet": {
                "reference_name": "string",
                "type": "string",
                "dataset_parameters": "any",
                "parameters": {
                    "string": "any",
                },
            },
            "linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "rejected_data_linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "schema_linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
        }],
        "sources": [{
            "name": "string",
            "dataset": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "description": "string",
            "flowlet": {
                "reference_name": "string",
                "type": "string",
                "dataset_parameters": "any",
                "parameters": {
                    "string": "any",
                },
            },
            "linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "schema_linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
        }],
        "transformations": [{
            "name": "string",
            "dataset": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
            "description": "string",
            "flowlet": {
                "reference_name": "string",
                "type": "string",
                "dataset_parameters": "any",
                "parameters": {
                    "string": "any",
                },
            },
            "linked_service": {
                "reference_name": "string",
                "type": "string",
                "parameters": {
                    "string": "any",
                },
            },
        }],
    },
    resource_group_name="string",
    data_flow_name="string")

    const dataFlowResource = new azure_native.datafactory.DataFlow("dataFlowResource", {
    factoryName: "string",
    properties: {
        type: "Flowlet",
        annotations: ["any"],
        description: "string",
        folder: {
            name: "string",
        },
        script: "string",
        scriptLines: ["string"],
        sinks: [{
            name: "string",
            dataset: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            description: "string",
            flowlet: {
                referenceName: "string",
                type: "string",
                datasetParameters: "any",
                parameters: {
                    string: "any",
                },
            },
            linkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            rejectedDataLinkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            schemaLinkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
        }],
        sources: [{
            name: "string",
            dataset: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            description: "string",
            flowlet: {
                referenceName: "string",
                type: "string",
                datasetParameters: "any",
                parameters: {
                    string: "any",
                },
            },
            linkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            schemaLinkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
        }],
        transformations: [{
            name: "string",
            dataset: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
            description: "string",
            flowlet: {
                referenceName: "string",
                type: "string",
                datasetParameters: "any",
                parameters: {
                    string: "any",
                },
            },
            linkedService: {
                referenceName: "string",
                type: "string",
                parameters: {
                    string: "any",
                },
            },
        }],
    },
    resourceGroupName: "string",
    dataFlowName: "string",
});

    type: azure-native:datafactory:DataFlow
properties:
    dataFlowName: string
    factoryName: string
    properties:
        annotations:
            - any
        description: string
        folder:
            name: string
        script: string
        scriptLines:
            - string
        sinks:
            - dataset:
                parameters:
                    string: any
                referenceName: string
                type: string
              description: string
              flowlet:
                datasetParameters: any
                parameters:
                    string: any
                referenceName: string
                type: string
              linkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
              name: string
              rejectedDataLinkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
              schemaLinkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
        sources:
            - dataset:
                parameters:
                    string: any
                referenceName: string
                type: string
              description: string
              flowlet:
                datasetParameters: any
                parameters:
                    string: any
                referenceName: string
                type: string
              linkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
              name: string
              schemaLinkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
        transformations:
            - dataset:
                parameters:
                    string: any
                referenceName: string
                type: string
              description: string
              flowlet:
                datasetParameters: any
                parameters:
                    string: any
                referenceName: string
                type: string
              linkedService:
                parameters:
                    string: any
                referenceName: string
                type: string
              name: string
        type: Flowlet
    resourceGroupName: string

    DataFlow Resource Properties

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

    Inputs

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

    The DataFlow resource accepts the following input properties:

    FactoryName string
    The factory name.
    Properties FlowletArgs | MappingDataFlowArgs | WranglingDataFlowArgs
    Data flow properties.
    ResourceGroupName string
    The resource group name.
    DataFlowName string
    The data flow name.
    factoryName String
    The factory name.
    properties Flowlet | MappingDataFlow | WranglingDataFlow
    Data flow properties.
    resourceGroupName String
    The resource group name.
    dataFlowName String
    The data flow name.
    factoryName string
    The factory name.
    properties Flowlet | MappingDataFlow | WranglingDataFlow
    Data flow properties.
    resourceGroupName string
    The resource group name.
    dataFlowName string
    The data flow name.
    factory_name str
    The factory name.
    properties FlowletArgs | MappingDataFlowArgs | WranglingDataFlowArgs
    Data flow properties.
    resource_group_name str
    The resource group name.
    data_flow_name str
    The data flow name.
    factoryName String
    The factory name.
    properties Property Map | Property Map | Property Map
    Data flow properties.
    resourceGroupName String
    The resource group name.
    dataFlowName String
    The data flow name.

    Outputs

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

    AzureApiVersion string
    The Azure API version of the resource.
    Etag string
    Etag identifies change in the resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The resource name.
    Type string
    The resource type.
    AzureApiVersion string
    The Azure API version of the resource.
    Etag string
    Etag identifies change in the resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The resource name.
    Type string
    The resource type.
    azureApiVersion String
    The Azure API version of the resource.
    etag String
    Etag identifies change in the resource.
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The resource name.
    type String
    The resource type.
    azureApiVersion string
    The Azure API version of the resource.
    etag string
    Etag identifies change in the resource.
    id string
    The provider-assigned unique ID for this managed resource.
    name string
    The resource name.
    type string
    The resource type.
    azure_api_version str
    The Azure API version of the resource.
    etag str
    Etag identifies change in the resource.
    id str
    The provider-assigned unique ID for this managed resource.
    name str
    The resource name.
    type str
    The resource type.
    azureApiVersion String
    The Azure API version of the resource.
    etag String
    Etag identifies change in the resource.
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The resource name.
    type String
    The resource type.

    Supporting Types

    DataFlowFolder, DataFlowFolderArgs

    Name string
    The name of the folder that this data flow is in.
    Name string
    The name of the folder that this data flow is in.
    name String
    The name of the folder that this data flow is in.
    name string
    The name of the folder that this data flow is in.
    name str
    The name of the folder that this data flow is in.
    name String
    The name of the folder that this data flow is in.

    DataFlowReference, DataFlowReferenceArgs

    ReferenceName string
    Reference data flow name.
    Type string | Pulumi.AzureNative.DataFactory.DataFlowReferenceType
    Data flow reference type.
    DatasetParameters object
    Reference data flow parameters from dataset.
    Parameters Dictionary<string, object>
    Data flow parameters
    ReferenceName string
    Reference data flow name.
    Type string | DataFlowReferenceType
    Data flow reference type.
    DatasetParameters interface{}
    Reference data flow parameters from dataset.
    Parameters map[string]interface{}
    Data flow parameters
    referenceName String
    Reference data flow name.
    type String | DataFlowReferenceType
    Data flow reference type.
    datasetParameters Object
    Reference data flow parameters from dataset.
    parameters Map<String,Object>
    Data flow parameters
    referenceName string
    Reference data flow name.
    type string | DataFlowReferenceType
    Data flow reference type.
    datasetParameters any
    Reference data flow parameters from dataset.
    parameters {[key: string]: any}
    Data flow parameters
    reference_name str
    Reference data flow name.
    type str | DataFlowReferenceType
    Data flow reference type.
    dataset_parameters Any
    Reference data flow parameters from dataset.
    parameters Mapping[str, Any]
    Data flow parameters
    referenceName String
    Reference data flow name.
    type String | "DataFlowReference"
    Data flow reference type.
    datasetParameters Any
    Reference data flow parameters from dataset.
    parameters Map<Any>
    Data flow parameters

    DataFlowReferenceResponse, DataFlowReferenceResponseArgs

    ReferenceName string
    Reference data flow name.
    Type string
    Data flow reference type.
    DatasetParameters object
    Reference data flow parameters from dataset.
    Parameters Dictionary<string, object>
    Data flow parameters
    ReferenceName string
    Reference data flow name.
    Type string
    Data flow reference type.
    DatasetParameters interface{}
    Reference data flow parameters from dataset.
    Parameters map[string]interface{}
    Data flow parameters
    referenceName String
    Reference data flow name.
    type String
    Data flow reference type.
    datasetParameters Object
    Reference data flow parameters from dataset.
    parameters Map<String,Object>
    Data flow parameters
    referenceName string
    Reference data flow name.
    type string
    Data flow reference type.
    datasetParameters any
    Reference data flow parameters from dataset.
    parameters {[key: string]: any}
    Data flow parameters
    reference_name str
    Reference data flow name.
    type str
    Data flow reference type.
    dataset_parameters Any
    Reference data flow parameters from dataset.
    parameters Mapping[str, Any]
    Data flow parameters
    referenceName String
    Reference data flow name.
    type String
    Data flow reference type.
    datasetParameters Any
    Reference data flow parameters from dataset.
    parameters Map<Any>
    Data flow parameters

    DataFlowReferenceType, DataFlowReferenceTypeArgs

    DataFlowReference
    DataFlowReference
    DataFlowReferenceTypeDataFlowReference
    DataFlowReference
    DataFlowReference
    DataFlowReference
    DataFlowReference
    DataFlowReference
    DATA_FLOW_REFERENCE
    DataFlowReference
    "DataFlowReference"
    DataFlowReference

    DataFlowResponseFolder, DataFlowResponseFolderArgs

    Name string
    The name of the folder that this data flow is in.
    Name string
    The name of the folder that this data flow is in.
    name String
    The name of the folder that this data flow is in.
    name string
    The name of the folder that this data flow is in.
    name str
    The name of the folder that this data flow is in.
    name String
    The name of the folder that this data flow is in.

    DataFlowSink, DataFlowSinkArgs

    Name string
    Transformation name.
    Dataset DatasetReference
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReference
    Flowlet Reference
    LinkedService LinkedServiceReference
    Linked service reference.
    RejectedDataLinkedService LinkedServiceReference
    Rejected data linked service reference.
    SchemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name String
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    rejectedDataLinkedService LinkedServiceReference
    Rejected data linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name string
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    rejectedDataLinkedService LinkedServiceReference
    Rejected data linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name str
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linked_service LinkedServiceReference
    Linked service reference.
    rejected_data_linked_service LinkedServiceReference
    Rejected data linked service reference.
    schema_linked_service LinkedServiceReference
    Schema linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    rejectedDataLinkedService Property Map
    Rejected data linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.

    DataFlowSinkResponse, DataFlowSinkResponseArgs

    Name string
    Transformation name.
    Dataset DatasetReferenceResponse
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReferenceResponse
    Flowlet Reference
    LinkedService LinkedServiceReferenceResponse
    Linked service reference.
    RejectedDataLinkedService LinkedServiceReferenceResponse
    Rejected data linked service reference.
    SchemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name String
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    rejectedDataLinkedService LinkedServiceReferenceResponse
    Rejected data linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name string
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    rejectedDataLinkedService LinkedServiceReferenceResponse
    Rejected data linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name str
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linked_service LinkedServiceReferenceResponse
    Linked service reference.
    rejected_data_linked_service LinkedServiceReferenceResponse
    Rejected data linked service reference.
    schema_linked_service LinkedServiceReferenceResponse
    Schema linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    rejectedDataLinkedService Property Map
    Rejected data linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.

    DataFlowSource, DataFlowSourceArgs

    Name string
    Transformation name.
    Dataset DatasetReference
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReference
    Flowlet Reference
    LinkedService LinkedServiceReference
    Linked service reference.
    SchemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name String
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name string
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    name str
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linked_service LinkedServiceReference
    Linked service reference.
    schema_linked_service LinkedServiceReference
    Schema linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.

    DataFlowSourceResponse, DataFlowSourceResponseArgs

    Name string
    Transformation name.
    Dataset DatasetReferenceResponse
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReferenceResponse
    Flowlet Reference
    LinkedService LinkedServiceReferenceResponse
    Linked service reference.
    SchemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name String
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name string
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    name str
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linked_service LinkedServiceReferenceResponse
    Linked service reference.
    schema_linked_service LinkedServiceReferenceResponse
    Schema linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.

    DatasetReference, DatasetReferenceArgs

    ReferenceName string
    Reference dataset name.
    Type string
    Dataset reference type.
    Parameters Dictionary<string, object>
    Arguments for dataset.
    ReferenceName string
    Reference dataset name.
    Type string
    Dataset reference type.
    Parameters map[string]interface{}
    Arguments for dataset.
    referenceName String
    Reference dataset name.
    type String
    Dataset reference type.
    parameters Map<String,Object>
    Arguments for dataset.
    referenceName string
    Reference dataset name.
    type string
    Dataset reference type.
    parameters {[key: string]: any}
    Arguments for dataset.
    reference_name str
    Reference dataset name.
    type str
    Dataset reference type.
    parameters Mapping[str, Any]
    Arguments for dataset.
    referenceName String
    Reference dataset name.
    type String
    Dataset reference type.
    parameters Map<Any>
    Arguments for dataset.

    DatasetReferenceResponse, DatasetReferenceResponseArgs

    ReferenceName string
    Reference dataset name.
    Type string
    Dataset reference type.
    Parameters Dictionary<string, object>
    Arguments for dataset.
    ReferenceName string
    Reference dataset name.
    Type string
    Dataset reference type.
    Parameters map[string]interface{}
    Arguments for dataset.
    referenceName String
    Reference dataset name.
    type String
    Dataset reference type.
    parameters Map<String,Object>
    Arguments for dataset.
    referenceName string
    Reference dataset name.
    type string
    Dataset reference type.
    parameters {[key: string]: any}
    Arguments for dataset.
    reference_name str
    Reference dataset name.
    type str
    Dataset reference type.
    parameters Mapping[str, Any]
    Arguments for dataset.
    referenceName String
    Reference dataset name.
    type String
    Dataset reference type.
    parameters Map<Any>
    Arguments for dataset.

    Flowlet, FlowletArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Flowlet script.
    ScriptLines List<string>
    Flowlet script lines.
    Sinks List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSink>
    List of sinks in Flowlet.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSource>
    List of sources in Flowlet.
    Transformations List<Pulumi.AzureNative.DataFactory.Inputs.Transformation>
    List of transformations in Flowlet.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Flowlet script.
    ScriptLines []string
    Flowlet script lines.
    Sinks []DataFlowSink
    List of sinks in Flowlet.
    Sources []DataFlowSource
    List of sources in Flowlet.
    Transformations []Transformation
    List of transformations in Flowlet.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Flowlet script.
    scriptLines List<String>
    Flowlet script lines.
    sinks List<DataFlowSink>
    List of sinks in Flowlet.
    sources List<DataFlowSource>
    List of sources in Flowlet.
    transformations List<Transformation>
    List of transformations in Flowlet.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    Flowlet script.
    scriptLines string[]
    Flowlet script lines.
    sinks DataFlowSink[]
    List of sinks in Flowlet.
    sources DataFlowSource[]
    List of sources in Flowlet.
    transformations Transformation[]
    List of transformations in Flowlet.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    Flowlet script.
    script_lines Sequence[str]
    Flowlet script lines.
    sinks Sequence[DataFlowSink]
    List of sinks in Flowlet.
    sources Sequence[DataFlowSource]
    List of sources in Flowlet.
    transformations Sequence[Transformation]
    List of transformations in Flowlet.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Flowlet script.
    scriptLines List<String>
    Flowlet script lines.
    sinks List<Property Map>
    List of sinks in Flowlet.
    sources List<Property Map>
    List of sources in Flowlet.
    transformations List<Property Map>
    List of transformations in Flowlet.

    FlowletResponse, FlowletResponseArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Flowlet script.
    ScriptLines List<string>
    Flowlet script lines.
    Sinks List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSinkResponse>
    List of sinks in Flowlet.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSourceResponse>
    List of sources in Flowlet.
    Transformations List<Pulumi.AzureNative.DataFactory.Inputs.TransformationResponse>
    List of transformations in Flowlet.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Flowlet script.
    ScriptLines []string
    Flowlet script lines.
    Sinks []DataFlowSinkResponse
    List of sinks in Flowlet.
    Sources []DataFlowSourceResponse
    List of sources in Flowlet.
    Transformations []TransformationResponse
    List of transformations in Flowlet.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Flowlet script.
    scriptLines List<String>
    Flowlet script lines.
    sinks List<DataFlowSinkResponse>
    List of sinks in Flowlet.
    sources List<DataFlowSourceResponse>
    List of sources in Flowlet.
    transformations List<TransformationResponse>
    List of transformations in Flowlet.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    Flowlet script.
    scriptLines string[]
    Flowlet script lines.
    sinks DataFlowSinkResponse[]
    List of sinks in Flowlet.
    sources DataFlowSourceResponse[]
    List of sources in Flowlet.
    transformations TransformationResponse[]
    List of transformations in Flowlet.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    Flowlet script.
    script_lines Sequence[str]
    Flowlet script lines.
    sinks Sequence[DataFlowSinkResponse]
    List of sinks in Flowlet.
    sources Sequence[DataFlowSourceResponse]
    List of sources in Flowlet.
    transformations Sequence[TransformationResponse]
    List of transformations in Flowlet.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Flowlet script.
    scriptLines List<String>
    Flowlet script lines.
    sinks List<Property Map>
    List of sinks in Flowlet.
    sources List<Property Map>
    List of sources in Flowlet.
    transformations List<Property Map>
    List of transformations in Flowlet.

    LinkedServiceReference, LinkedServiceReferenceArgs

    ReferenceName string
    Reference LinkedService name.
    Type string | Pulumi.AzureNative.DataFactory.Type
    Linked service reference type.
    Parameters Dictionary<string, object>
    Arguments for LinkedService.
    ReferenceName string
    Reference LinkedService name.
    Type string | Type
    Linked service reference type.
    Parameters map[string]interface{}
    Arguments for LinkedService.
    referenceName String
    Reference LinkedService name.
    type String | Type
    Linked service reference type.
    parameters Map<String,Object>
    Arguments for LinkedService.
    referenceName string
    Reference LinkedService name.
    type string | Type
    Linked service reference type.
    parameters {[key: string]: any}
    Arguments for LinkedService.
    reference_name str
    Reference LinkedService name.
    type str | Type
    Linked service reference type.
    parameters Mapping[str, Any]
    Arguments for LinkedService.
    referenceName String
    Reference LinkedService name.
    type String | "LinkedServiceReference"
    Linked service reference type.
    parameters Map<Any>
    Arguments for LinkedService.

    LinkedServiceReferenceResponse, LinkedServiceReferenceResponseArgs

    ReferenceName string
    Reference LinkedService name.
    Type string
    Linked service reference type.
    Parameters Dictionary<string, object>
    Arguments for LinkedService.
    ReferenceName string
    Reference LinkedService name.
    Type string
    Linked service reference type.
    Parameters map[string]interface{}
    Arguments for LinkedService.
    referenceName String
    Reference LinkedService name.
    type String
    Linked service reference type.
    parameters Map<String,Object>
    Arguments for LinkedService.
    referenceName string
    Reference LinkedService name.
    type string
    Linked service reference type.
    parameters {[key: string]: any}
    Arguments for LinkedService.
    reference_name str
    Reference LinkedService name.
    type str
    Linked service reference type.
    parameters Mapping[str, Any]
    Arguments for LinkedService.
    referenceName String
    Reference LinkedService name.
    type String
    Linked service reference type.
    parameters Map<Any>
    Arguments for LinkedService.

    MappingDataFlow, MappingDataFlowArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    DataFlow script.
    ScriptLines List<string>
    Data flow script lines.
    Sinks List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSink>
    List of sinks in data flow.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSource>
    List of sources in data flow.
    Transformations List<Pulumi.AzureNative.DataFactory.Inputs.Transformation>
    List of transformations in data flow.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    DataFlow script.
    ScriptLines []string
    Data flow script lines.
    Sinks []DataFlowSink
    List of sinks in data flow.
    Sources []DataFlowSource
    List of sources in data flow.
    Transformations []Transformation
    List of transformations in data flow.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    DataFlow script.
    scriptLines List<String>
    Data flow script lines.
    sinks List<DataFlowSink>
    List of sinks in data flow.
    sources List<DataFlowSource>
    List of sources in data flow.
    transformations List<Transformation>
    List of transformations in data flow.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    DataFlow script.
    scriptLines string[]
    Data flow script lines.
    sinks DataFlowSink[]
    List of sinks in data flow.
    sources DataFlowSource[]
    List of sources in data flow.
    transformations Transformation[]
    List of transformations in data flow.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    DataFlow script.
    script_lines Sequence[str]
    Data flow script lines.
    sinks Sequence[DataFlowSink]
    List of sinks in data flow.
    sources Sequence[DataFlowSource]
    List of sources in data flow.
    transformations Sequence[Transformation]
    List of transformations in data flow.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    DataFlow script.
    scriptLines List<String>
    Data flow script lines.
    sinks List<Property Map>
    List of sinks in data flow.
    sources List<Property Map>
    List of sources in data flow.
    transformations List<Property Map>
    List of transformations in data flow.

    MappingDataFlowResponse, MappingDataFlowResponseArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    DataFlow script.
    ScriptLines List<string>
    Data flow script lines.
    Sinks List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSinkResponse>
    List of sinks in data flow.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.DataFlowSourceResponse>
    List of sources in data flow.
    Transformations List<Pulumi.AzureNative.DataFactory.Inputs.TransformationResponse>
    List of transformations in data flow.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    Folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    DataFlow script.
    ScriptLines []string
    Data flow script lines.
    Sinks []DataFlowSinkResponse
    List of sinks in data flow.
    Sources []DataFlowSourceResponse
    List of sources in data flow.
    Transformations []TransformationResponse
    List of transformations in data flow.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    DataFlow script.
    scriptLines List<String>
    Data flow script lines.
    sinks List<DataFlowSinkResponse>
    List of sinks in data flow.
    sources List<DataFlowSourceResponse>
    List of sources in data flow.
    transformations List<TransformationResponse>
    List of transformations in data flow.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    DataFlow script.
    scriptLines string[]
    Data flow script lines.
    sinks DataFlowSinkResponse[]
    List of sinks in data flow.
    sources DataFlowSourceResponse[]
    List of sources in data flow.
    transformations TransformationResponse[]
    List of transformations in data flow.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    DataFlow script.
    script_lines Sequence[str]
    Data flow script lines.
    sinks Sequence[DataFlowSinkResponse]
    List of sinks in data flow.
    sources Sequence[DataFlowSourceResponse]
    List of sources in data flow.
    transformations Sequence[TransformationResponse]
    List of transformations in data flow.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    DataFlow script.
    scriptLines List<String>
    Data flow script lines.
    sinks List<Property Map>
    List of sinks in data flow.
    sources List<Property Map>
    List of sources in data flow.
    transformations List<Property Map>
    List of transformations in data flow.

    PowerQuerySource, PowerQuerySourceArgs

    Name string
    Transformation name.
    Dataset DatasetReference
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReference
    Flowlet Reference
    LinkedService LinkedServiceReference
    Linked service reference.
    SchemaLinkedService LinkedServiceReference
    Schema linked service reference.
    Script string
    source script.
    name String
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    script String
    source script.
    name string
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    schemaLinkedService LinkedServiceReference
    Schema linked service reference.
    script string
    source script.
    name str
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linked_service LinkedServiceReference
    Linked service reference.
    schema_linked_service LinkedServiceReference
    Schema linked service reference.
    script str
    source script.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.
    script String
    source script.

    PowerQuerySourceResponse, PowerQuerySourceResponseArgs

    Name string
    Transformation name.
    Dataset DatasetReferenceResponse
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReferenceResponse
    Flowlet Reference
    LinkedService LinkedServiceReferenceResponse
    Linked service reference.
    SchemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    Script string
    source script.
    name String
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    script String
    source script.
    name string
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    schemaLinkedService LinkedServiceReferenceResponse
    Schema linked service reference.
    script string
    source script.
    name str
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linked_service LinkedServiceReferenceResponse
    Linked service reference.
    schema_linked_service LinkedServiceReferenceResponse
    Schema linked service reference.
    script str
    source script.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.
    schemaLinkedService Property Map
    Schema linked service reference.
    script String
    source script.

    Transformation, TransformationArgs

    Name string
    Transformation name.
    Dataset DatasetReference
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReference
    Flowlet Reference
    LinkedService LinkedServiceReference
    Linked service reference.
    name String
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    name string
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linkedService LinkedServiceReference
    Linked service reference.
    name str
    Transformation name.
    dataset DatasetReference
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReference
    Flowlet Reference
    linked_service LinkedServiceReference
    Linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.

    TransformationResponse, TransformationResponseArgs

    Name string
    Transformation name.
    Dataset DatasetReferenceResponse
    Dataset reference.
    Description string
    Transformation description.
    Flowlet DataFlowReferenceResponse
    Flowlet Reference
    LinkedService LinkedServiceReferenceResponse
    Linked service reference.
    name String
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description String
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    name string
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description string
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linkedService LinkedServiceReferenceResponse
    Linked service reference.
    name str
    Transformation name.
    dataset DatasetReferenceResponse
    Dataset reference.
    description str
    Transformation description.
    flowlet DataFlowReferenceResponse
    Flowlet Reference
    linked_service LinkedServiceReferenceResponse
    Linked service reference.
    name String
    Transformation name.
    dataset Property Map
    Dataset reference.
    description String
    Transformation description.
    flowlet Property Map
    Flowlet Reference
    linkedService Property Map
    Linked service reference.

    Type, TypeArgs

    LinkedServiceReference
    LinkedServiceReference
    TypeLinkedServiceReference
    LinkedServiceReference
    LinkedServiceReference
    LinkedServiceReference
    LinkedServiceReference
    LinkedServiceReference
    LINKED_SERVICE_REFERENCE
    LinkedServiceReference
    "LinkedServiceReference"
    LinkedServiceReference

    WranglingDataFlow, WranglingDataFlowArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    DocumentLocale string
    Locale of the Power query mashup document.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Power query mashup script.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.PowerQuerySource>
    List of sources in Power Query.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    DocumentLocale string
    Locale of the Power query mashup document.
    Folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Power query mashup script.
    Sources []PowerQuerySource
    List of sources in Power Query.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    documentLocale String
    Locale of the Power query mashup document.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Power query mashup script.
    sources List<PowerQuerySource>
    List of sources in Power Query.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    documentLocale string
    Locale of the Power query mashup document.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    Power query mashup script.
    sources PowerQuerySource[]
    List of sources in Power Query.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    document_locale str
    Locale of the Power query mashup document.
    folder DataFlowFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    Power query mashup script.
    sources Sequence[PowerQuerySource]
    List of sources in Power Query.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    documentLocale String
    Locale of the Power query mashup document.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Power query mashup script.
    sources List<Property Map>
    List of sources in Power Query.

    WranglingDataFlowResponse, WranglingDataFlowResponseArgs

    Annotations List<object>
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    DocumentLocale string
    Locale of the Power query mashup document.
    Folder Pulumi.AzureNative.DataFactory.Inputs.DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Power query mashup script.
    Sources List<Pulumi.AzureNative.DataFactory.Inputs.PowerQuerySourceResponse>
    List of sources in Power Query.
    Annotations []interface{}
    List of tags that can be used for describing the data flow.
    Description string
    The description of the data flow.
    DocumentLocale string
    Locale of the Power query mashup document.
    Folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    Script string
    Power query mashup script.
    Sources []PowerQuerySourceResponse
    List of sources in Power Query.
    annotations List<Object>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    documentLocale String
    Locale of the Power query mashup document.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Power query mashup script.
    sources List<PowerQuerySourceResponse>
    List of sources in Power Query.
    annotations any[]
    List of tags that can be used for describing the data flow.
    description string
    The description of the data flow.
    documentLocale string
    Locale of the Power query mashup document.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script string
    Power query mashup script.
    sources PowerQuerySourceResponse[]
    List of sources in Power Query.
    annotations Sequence[Any]
    List of tags that can be used for describing the data flow.
    description str
    The description of the data flow.
    document_locale str
    Locale of the Power query mashup document.
    folder DataFlowResponseFolder
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script str
    Power query mashup script.
    sources Sequence[PowerQuerySourceResponse]
    List of sources in Power Query.
    annotations List<Any>
    List of tags that can be used for describing the data flow.
    description String
    The description of the data flow.
    documentLocale String
    Locale of the Power query mashup document.
    folder Property Map
    The folder that this data flow is in. If not specified, Data flow will appear at the root level.
    script String
    Power query mashup script.
    sources List<Property Map>
    List of sources in Power Query.

    Import

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

    $ pulumi import azure-native:datafactory:DataFlow exampleDataFlow /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/dataflows/{dataFlowName}

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

    Package Details

    Repository
    Azure Native pulumi/pulumi-azure-native
    License
    Apache-2.0
    azure-native logo
    This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
    Azure Native v3.4.0 published on Wednesday, May 7, 2025 by Pulumi
    pulumi/pulumi-azure-native