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

azure-native-v2.datafactory.DataFlow

Explore with Pulumi AI

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

Data flow resource type. Azure REST API version: 2018-06-01. Prior API version in Azure Native 1.x: 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",
    });

});
Copy
package main

import (
	datafactory "github.com/pulumi/pulumi-azure-native-sdk/datafactory/v2"
	"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
	})
}
Copy
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());

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

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

});
Copy
package main

import (
	datafactory "github.com/pulumi/pulumi-azure-native-sdk/datafactory/v2"
	"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
	})
}
Copy
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());

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

Create DataFlow Resource

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

Constructor syntax

new DataFlow(name: string, args: DataFlowArgs, opts?: CustomResourceOptions);
@overload
def DataFlow(resource_name: str,
             args: DataFlowArgs,
             opts: Optional[ResourceOptions] = None)

@overload
def DataFlow(resource_name: str,
             opts: Optional[ResourceOptions] = None,
             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 This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name This property is required. str
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts ResourceOptions
Bag of options to control resource's behavior.
ctx Context
Context object for the current deployment.
name This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name This property is required. string
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
name This property is required. String
The unique name of the resource.
args This property is required. DataFlowArgs
The arguments to resource properties.
options CustomResourceOptions
Bag of options to control resource's behavior.

Constructor example

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

var dataFlowResource = new AzureNative.Datafactory.DataFlow("dataFlowResource", new()
{
    FactoryName = "string",
    Properties = 
    {
        { "type", "Flowlet" },
        { "annotations", new[]
        {
            "any",
        } },
        { "description", "string" },
        { "folder", 
        {
            { "name", "string" },
        } },
        { "script", "string" },
        { "scriptLines", new[]
        {
            "string",
        } },
        { "sinks", new[]
        {
            
            {
                { "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", new[]
        {
            
            {
                { "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", new[]
        {
            
            {
                { "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",
});
Copy
example, err := datafactory.NewDataFlow(ctx, "dataFlowResource", &datafactory.DataFlowArgs{
	FactoryName: "string",
	Properties: map[string]interface{}{
		"type": "Flowlet",
		"annotations": []string{
			"any",
		},
		"description": "string",
		"folder": map[string]interface{}{
			"name": "string",
		},
		"script": "string",
		"scriptLines": []string{
			"string",
		},
		"sinks": []map[string]interface{}{
			map[string]interface{}{
				"name": "string",
				"dataset": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"description": "string",
				"flowlet": map[string]interface{}{
					"referenceName":     "string",
					"type":              "string",
					"datasetParameters": "any",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"linkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"rejectedDataLinkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"schemaLinkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
			},
		},
		"sources": []map[string]interface{}{
			map[string]interface{}{
				"name": "string",
				"dataset": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"description": "string",
				"flowlet": map[string]interface{}{
					"referenceName":     "string",
					"type":              "string",
					"datasetParameters": "any",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"linkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"schemaLinkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
			},
		},
		"transformations": []map[string]interface{}{
			map[string]interface{}{
				"name": "string",
				"dataset": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"description": "string",
				"flowlet": map[string]interface{}{
					"referenceName":     "string",
					"type":              "string",
					"datasetParameters": "any",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
				"linkedService": map[string]interface{}{
					"referenceName": "string",
					"type":          "string",
					"parameters": map[string]interface{}{
						"string": "any",
					},
				},
			},
		},
	},
	ResourceGroupName: "string",
	DataFlowName:      "string",
})
Copy
var dataFlowResource = new com.pulumi.azurenative.datafactory.DataFlow("dataFlowResource", com.pulumi.azurenative.datafactory.DataFlowArgs.builder()
    .factoryName("string")
    .properties(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
    .resourceGroupName("string")
    .dataFlowName("string")
    .build());
Copy
data_flow_resource = azure_native.datafactory.DataFlow("dataFlowResource",
    factory_name=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,
                },
            },
        }],
    },
    resource_group_name=string,
    data_flow_name=string)
Copy
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",
});
Copy
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
Copy

DataFlow Resource Properties

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

Inputs

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

The DataFlow resource accepts the following input properties:

FactoryName
This property is required.
Changes to this property will trigger replacement.
string
The factory name.
Properties This property is required. Pulumi.AzureNative.DataFactory.Inputs.Flowlet | Pulumi.AzureNative.DataFactory.Inputs.MappingDataFlow | Pulumi.AzureNative.DataFactory.Inputs.WranglingDataFlow
Data flow properties.
ResourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The resource group name.
DataFlowName Changes to this property will trigger replacement. string
The data flow name.
FactoryName
This property is required.
Changes to this property will trigger replacement.
string
The factory name.
Properties This property is required. FlowletArgs | MappingDataFlowArgs | WranglingDataFlowArgs
Data flow properties.
ResourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The resource group name.
DataFlowName Changes to this property will trigger replacement. string
The data flow name.
factoryName
This property is required.
Changes to this property will trigger replacement.
String
The factory name.
properties This property is required. Flowlet | MappingDataFlow | WranglingDataFlow
Data flow properties.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
String
The resource group name.
dataFlowName Changes to this property will trigger replacement. String
The data flow name.
factoryName
This property is required.
Changes to this property will trigger replacement.
string
The factory name.
properties This property is required. Flowlet | MappingDataFlow | WranglingDataFlow
Data flow properties.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
string
The resource group name.
dataFlowName Changes to this property will trigger replacement. string
The data flow name.
factory_name
This property is required.
Changes to this property will trigger replacement.
str
The factory name.
properties This property is required. FlowletArgs | MappingDataFlowArgs | WranglingDataFlowArgs
Data flow properties.
resource_group_name
This property is required.
Changes to this property will trigger replacement.
str
The resource group name.
data_flow_name Changes to this property will trigger replacement. str
The data flow name.
factoryName
This property is required.
Changes to this property will trigger replacement.
String
The factory name.
properties This property is required. Property Map | Property Map | Property Map
Data flow properties.
resourceGroupName
This property is required.
Changes to this property will trigger replacement.
String
The resource group name.
dataFlowName Changes to this property will trigger replacement. String
The data flow name.

Outputs

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

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.
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.
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.
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.
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.
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 This property is required. string
Reference data flow name.
Type This property is required. 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 This property is required. string
Reference data flow name.
Type This property is required. string | DataFlowReferenceType
Data flow reference type.
DatasetParameters interface{}
Reference data flow parameters from dataset.
Parameters map[string]interface{}
Data flow parameters
referenceName This property is required. String
Reference data flow name.
type This property is required. String | DataFlowReferenceType
Data flow reference type.
datasetParameters Object
Reference data flow parameters from dataset.
parameters Map<String,Object>
Data flow parameters
referenceName This property is required. string
Reference data flow name.
type This property is required. string | DataFlowReferenceType
Data flow reference type.
datasetParameters any
Reference data flow parameters from dataset.
parameters {[key: string]: any}
Data flow parameters
reference_name This property is required. str
Reference data flow name.
type This property is required. str | DataFlowReferenceType
Data flow reference type.
dataset_parameters Any
Reference data flow parameters from dataset.
parameters Mapping[str, Any]
Data flow parameters
referenceName This property is required. String
Reference data flow name.
type This property is required. String | "DataFlowReference"
Data flow reference type.
datasetParameters Any
Reference data flow parameters from dataset.
parameters Map<Any>
Data flow parameters

DataFlowReferenceResponse
, DataFlowReferenceResponseArgs

ReferenceName This property is required. string
Reference data flow name.
Type This property is required. string
Data flow reference type.
DatasetParameters object
Reference data flow parameters from dataset.
Parameters Dictionary<string, object>
Data flow parameters
ReferenceName This property is required. string
Reference data flow name.
Type This property is required. string
Data flow reference type.
DatasetParameters interface{}
Reference data flow parameters from dataset.
Parameters map[string]interface{}
Data flow parameters
referenceName This property is required. String
Reference data flow name.
type This property is required. String
Data flow reference type.
datasetParameters Object
Reference data flow parameters from dataset.
parameters Map<String,Object>
Data flow parameters
referenceName This property is required. string
Reference data flow name.
type This property is required. string
Data flow reference type.
datasetParameters any
Reference data flow parameters from dataset.
parameters {[key: string]: any}
Data flow parameters
reference_name This property is required. str
Reference data flow name.
type This property is required. str
Data flow reference type.
dataset_parameters Any
Reference data flow parameters from dataset.
parameters Mapping[str, Any]
Data flow parameters
referenceName This property is required. String
Reference data flow name.
type This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. string
Reference dataset name.
Type This property is required. string
Dataset reference type.
Parameters Dictionary<string, object>
Arguments for dataset.
ReferenceName This property is required. string
Reference dataset name.
Type This property is required. string
Dataset reference type.
Parameters map[string]interface{}
Arguments for dataset.
referenceName This property is required. String
Reference dataset name.
type This property is required. String
Dataset reference type.
parameters Map<String,Object>
Arguments for dataset.
referenceName This property is required. string
Reference dataset name.
type This property is required. string
Dataset reference type.
parameters {[key: string]: any}
Arguments for dataset.
reference_name This property is required. str
Reference dataset name.
type This property is required. str
Dataset reference type.
parameters Mapping[str, Any]
Arguments for dataset.
referenceName This property is required. String
Reference dataset name.
type This property is required. String
Dataset reference type.
parameters Map<Any>
Arguments for dataset.

DatasetReferenceResponse
, DatasetReferenceResponseArgs

ReferenceName This property is required. string
Reference dataset name.
Type This property is required. string
Dataset reference type.
Parameters Dictionary<string, object>
Arguments for dataset.
ReferenceName This property is required. string
Reference dataset name.
Type This property is required. string
Dataset reference type.
Parameters map[string]interface{}
Arguments for dataset.
referenceName This property is required. String
Reference dataset name.
type This property is required. String
Dataset reference type.
parameters Map<String,Object>
Arguments for dataset.
referenceName This property is required. string
Reference dataset name.
type This property is required. string
Dataset reference type.
parameters {[key: string]: any}
Arguments for dataset.
reference_name This property is required. str
Reference dataset name.
type This property is required. str
Dataset reference type.
parameters Mapping[str, Any]
Arguments for dataset.
referenceName This property is required. String
Reference dataset name.
type This property is required. 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 This property is required. string
Reference LinkedService name.
Type This property is required. string | Pulumi.AzureNative.DataFactory.Type
Linked service reference type.
Parameters Dictionary<string, object>
Arguments for LinkedService.
ReferenceName This property is required. string
Reference LinkedService name.
Type This property is required. string | Type
Linked service reference type.
Parameters map[string]interface{}
Arguments for LinkedService.
referenceName This property is required. String
Reference LinkedService name.
type This property is required. String | Type
Linked service reference type.
parameters Map<String,Object>
Arguments for LinkedService.
referenceName This property is required. string
Reference LinkedService name.
type This property is required. string | Type
Linked service reference type.
parameters {[key: string]: any}
Arguments for LinkedService.
reference_name This property is required. str
Reference LinkedService name.
type This property is required. str | Type
Linked service reference type.
parameters Mapping[str, Any]
Arguments for LinkedService.
referenceName This property is required. String
Reference LinkedService name.
type This property is required. String | "LinkedServiceReference"
Linked service reference type.
parameters Map<Any>
Arguments for LinkedService.

LinkedServiceReferenceResponse
, LinkedServiceReferenceResponseArgs

ReferenceName This property is required. string
Reference LinkedService name.
Type This property is required. string
Linked service reference type.
Parameters Dictionary<string, object>
Arguments for LinkedService.
ReferenceName This property is required. string
Reference LinkedService name.
Type This property is required. string
Linked service reference type.
Parameters map[string]interface{}
Arguments for LinkedService.
referenceName This property is required. String
Reference LinkedService name.
type This property is required. String
Linked service reference type.
parameters Map<String,Object>
Arguments for LinkedService.
referenceName This property is required. string
Reference LinkedService name.
type This property is required. string
Linked service reference type.
parameters {[key: string]: any}
Arguments for LinkedService.
reference_name This property is required. str
Reference LinkedService name.
type This property is required. str
Linked service reference type.
parameters Mapping[str, Any]
Arguments for LinkedService.
referenceName This property is required. String
Reference LinkedService name.
type This property is required. 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 This property is required. string
Transformation name.
Dataset Pulumi.AzureNative.DataFactory.Inputs.DatasetReference
Dataset reference.
Description string
Transformation description.
Flowlet Pulumi.AzureNative.DataFactory.Inputs.DataFlowReference
Flowlet Reference
LinkedService Pulumi.AzureNative.DataFactory.Inputs.LinkedServiceReference
Linked service reference.
SchemaLinkedService Pulumi.AzureNative.DataFactory.Inputs.LinkedServiceReference
Schema linked service reference.
Script string
source script.
Name This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. string
Transformation name.
Dataset Pulumi.AzureNative.DataFactory.Inputs.DatasetReference
Dataset reference.
Description string
Transformation description.
Flowlet Pulumi.AzureNative.DataFactory.Inputs.DataFlowReference
Flowlet Reference
LinkedService Pulumi.AzureNative.DataFactory.Inputs.LinkedServiceReference
Linked service reference.
Name This property is required. string
Transformation name.
Dataset DatasetReference
Dataset reference.
Description string
Transformation description.
Flowlet DataFlowReference
Flowlet Reference
LinkedService LinkedServiceReference
Linked service reference.
name This property is required. String
Transformation name.
dataset DatasetReference
Dataset reference.
description String
Transformation description.
flowlet DataFlowReference
Flowlet Reference
linkedService LinkedServiceReference
Linked service reference.
name This property is required. string
Transformation name.
dataset DatasetReference
Dataset reference.
description string
Transformation description.
flowlet DataFlowReference
Flowlet Reference
linkedService LinkedServiceReference
Linked service reference.
name This property is required. str
Transformation name.
dataset DatasetReference
Dataset reference.
description str
Transformation description.
flowlet DataFlowReference
Flowlet Reference
linked_service LinkedServiceReference
Linked service reference.
name This property is required. 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 This property is required. string
Transformation name.
Dataset DatasetReferenceResponse
Dataset reference.
Description string
Transformation description.
Flowlet DataFlowReferenceResponse
Flowlet Reference
LinkedService LinkedServiceReferenceResponse
Linked service reference.
name This property is required. String
Transformation name.
dataset DatasetReferenceResponse
Dataset reference.
description String
Transformation description.
flowlet DataFlowReferenceResponse
Flowlet Reference
linkedService LinkedServiceReferenceResponse
Linked service reference.
name This property is required. string
Transformation name.
dataset DatasetReferenceResponse
Dataset reference.
description string
Transformation description.
flowlet DataFlowReferenceResponse
Flowlet Reference
linkedService LinkedServiceReferenceResponse
Linked service reference.
name This property is required. str
Transformation name.
dataset DatasetReferenceResponse
Dataset reference.
description str
Transformation description.
flowlet DataFlowReferenceResponse
Flowlet Reference
linked_service LinkedServiceReferenceResponse
Linked service reference.
name This property is required. 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}
Copy

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

Package Details

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