pulumi-azure-kotlin/com.pulumi.azure.datafactory.kotlin/Pipeline

Pipeline

class Pipeline : KotlinCustomResource

Manages a Pipeline inside a Azure Data Factory.

Example Usage

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.datafactory.Factory;
import com.pulumi.azure.datafactory.FactoryArgs;
import com.pulumi.azure.datafactory.Pipeline;
import com.pulumi.azure.datafactory.PipelineArgs;
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 exampleResourceGroup = new ResourceGroup("exampleResourceGroup", ResourceGroupArgs.builder()
            .location("West Europe")
            .build());
        var exampleFactory = new Factory("exampleFactory", FactoryArgs.builder()
            .location(exampleResourceGroup.location())
            .resourceGroupName(exampleResourceGroup.name())
            .build());
        var examplePipeline = new Pipeline("examplePipeline", PipelineArgs.builder()
            .dataFactoryId(exampleFactory.id())
            .build());
    }
}

With Activities

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.datafactory.Pipeline;
import com.pulumi.azure.datafactory.PipelineArgs;
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 test = new Pipeline("test", PipelineArgs.builder()
            .dataFactoryId(azurerm_data_factory.test().id())
            .variables(Map.of("bob", "item1"))
            .activitiesJson("""
[
    {
        "name": "Append variable1",
        "type": "AppendVariable",
        "dependsOn": [],
        "userProperties": [],
        "typeProperties": {
          "variableName": "bob",
          "value": "something"
        }
    }
]
            """)
            .build());
    }
}

Import

Data Factory Pipeline's can be imported using the resource id, e.g.

$ pulumi import azure:datafactory/pipeline:Pipeline example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/example/providers/Microsoft.DataFactory/factories/example/pipelines/example

Properties

activitiesJson

val activitiesJson: Output<String>?

A JSON object that contains the activities that will be associated with the Data Factory Pipeline.

annotations

val annotations: Output<List<String>>?

List of tags that can be used for describing the Data Factory Pipeline.

concurrency

val concurrency: Output<Int>?

The max number of concurrent runs for the Data Factory Pipeline. Must be between 1 and 50.

dataFactoryId

val dataFactoryId: Output<String>

The Data Factory ID in which to associate the Linked Service with. Changing this forces a new resource.

description

val description: Output<String>?

The description for the Data Factory Pipeline.

folder

val folder: Output<String>?

The folder that this Pipeline is in. If not specified, the Pipeline will appear at the root level.

val id: Output<String>

moniterMetricsAfterDuration

val moniterMetricsAfterDuration: Output<String>?

The TimeSpan value after which an Azure Monitoring Metric is fired.

name

val name: Output<String>

Specifies the name of the Data Factory Pipeline. Changing this forces a new resource to be created. Must be globally unique. See the Microsoft documentation for all restrictions.

parameters

val parameters: Output<Map<String, String>>?

A map of parameters to associate with the Data Factory Pipeline.

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

urn

val urn: Output<String>

variables

val variables: Output<Map<String, String>>?

A map of variables to associate with the Data Factory Pipeline.