Pipelines - Create Or Update

Service:

Data Factory

Version d'API:

2018-06-01

Crée ou met à jour un pipeline.

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/pipelines/{pipelineName}?api-version=2018-06-01

Paramètres URI

Nom	Dans	Obligatoire	Type	Description
factoryName	path	True	string	Nom de la fabrique. Modèle d’expression régulière: ^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$
pipelineName	path	True	string	Nom du pipeline. Modèle d’expression régulière: ^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$
resourceGroupName	path	True	string	Nom du groupe de ressources. Modèle d’expression régulière: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	Identificateur d’abonnement.
api-version	query	True	string	Version de l’API.

En-tête de la demande

Nom	Obligatoire	Type	Description
If-Match		string	ETag de l’entité de pipeline. Doit être spécifié uniquement pour la mise à jour, pour laquelle elle doit correspondre à une entité existante ou peut être * pour une mise à jour inconditionnelle.

Corps de la demande

Nom	Type	Description
properties.activities	Activity[]: ControlActivity[] ExecutionActivity[] ExecuteWranglingDataflowActivity[] CopyActivity[] HDInsightHiveActivity[] HDInsightPigActivity[] HDInsightMapReduceActivity[] HDInsightStreamingActivity[] HDInsightSparkActivity[] ExecuteSSISPackageActivity[] CustomActivity[] SqlServerStoredProcedureActivity[] DeleteActivity[] AzureDataExplorerCommandActivity[] LookupActivity[] WebActivity[] GetMetadataActivity[] AzureMLBatchExecutionActivity[] AzureMLUpdateResourceActivity[] AzureMLExecutePipelineActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] AzureFunctionActivity[] ExecuteDataFlowActivity[] ScriptActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] ExecutePipelineActivity[] IfConditionActivity[] SwitchActivity[] ForEachActivity[] WaitActivity[] FailActivity[] UntilActivity[] ValidationActivity[] FilterActivity[] SetVariableActivity[] AppendVariableActivity[] WebHookActivity[]	Liste des activités dans le pipeline.
properties.annotations	object[]	Liste des balises qui peuvent être utilisées pour décrire le pipeline.
properties.concurrency	integer	Nombre maximal d’exécutions simultanées pour le pipeline.
properties.description	string	Description du pipeline.
properties.folder	Folder	Dossier dans lequel se trouve ce pipeline. S’il n’est pas spécifié, le pipeline apparaît au niveau racine.
properties.parameters	<string,  ParameterSpecification>	Liste des paramètres du pipeline.
properties.policy	PipelinePolicy	Stratégie de pipeline.
properties.runDimensions	object	Dimensions émises par pipeline.
properties.variables	<string,  VariableSpecification>	Liste des variables pour le pipeline.

Réponses

Nom	Type	Description
200 OK	PipelineResource	D’ACCORD.
Other Status Codes	CloudError	Réponse d’erreur reçue du service Azure Data Factory.

Sécurité

azure_auth

Flux OAuth2 Azure Active Directory.

Type: oauth2
Flux: implicit
URL d’autorisation: https://login.microsoftonline.com/common/oauth2/authorize

Étendues

Nom	Description
user_impersonation	emprunter l’identité de votre compte d’utilisateur

Exemples

Pipelines_Create

Pipelines_Update

Pipelines_Create

Exemple de requête

HTTP

PUT https://management.azure.com/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline?api-version=2018-06-01

{
  "properties": {
    "activities": [
      {
        "type": "ForEach",
        "typeProperties": {
          "isSequential": true,
          "items": {
            "value": "@pipeline().parameters.OutputBlobNameList",
            "type": "Expression"
          },
          "activities": [
            {
              "type": "Copy",
              "typeProperties": {
                "source": {
                  "type": "BlobSource"
                },
                "sink": {
                  "type": "BlobSink"
                },
                "dataIntegrationUnits": 32
              },
              "inputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": "examplecontainer.csv"
                  },
                  "type": "DatasetReference"
                }
              ],
              "outputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": {
                      "value": "@item()",
                      "type": "Expression"
                    }
                  },
                  "type": "DatasetReference"
                }
              ],
              "name": "ExampleCopyActivity"
            }
          ]
        },
        "name": "ExampleForeachActivity"
      }
    ],
    "parameters": {
      "OutputBlobNameList": {
        "type": "Array"
      },
      "JobId": {
        "type": "String"
      }
    },
    "variables": {
      "TestVariableArray": {
        "type": "Array"
      }
    },
    "runDimensions": {
      "JobId": {
        "value": "@pipeline().parameters.JobId",
        "type": "Expression"
      }
    },
    "policy": {
      "elapsedTimeMetric": {
        "duration": "0.00:10:00"
      }
    }
  }
}

Java

import com.azure.core.management.serializer.SerializerFactory;
import com.azure.core.util.serializer.SerializerEncoding;
import com.azure.resourcemanager.datafactory.models.BlobSink;
import com.azure.resourcemanager.datafactory.models.BlobSource;
import com.azure.resourcemanager.datafactory.models.CopyActivity;
import com.azure.resourcemanager.datafactory.models.DatasetReference;
import com.azure.resourcemanager.datafactory.models.Expression;
import com.azure.resourcemanager.datafactory.models.ForEachActivity;
import com.azure.resourcemanager.datafactory.models.ParameterSpecification;
import com.azure.resourcemanager.datafactory.models.ParameterType;
import com.azure.resourcemanager.datafactory.models.PipelineElapsedTimeMetricPolicy;
import com.azure.resourcemanager.datafactory.models.PipelinePolicy;
import com.azure.resourcemanager.datafactory.models.VariableSpecification;
import com.azure.resourcemanager.datafactory.models.VariableType;
import java.io.IOException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Pipelines CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Create.json
     */
    /**
     * Sample code: Pipelines_Create.
     * 
     * @param manager Entry point to DataFactoryManager.
     */
    public static void pipelinesCreate(com.azure.resourcemanager.datafactory.DataFactoryManager manager)
        throws IOException {
        manager.pipelines().define("examplePipeline").withExistingFactory("exampleResourceGroup", "exampleFactoryName")
            .withActivities(Arrays.asList(new ForEachActivity().withName("ExampleForeachActivity")
                .withIsSequential(true)
                .withItems(new Expression().withValue("@pipeline().parameters.OutputBlobNameList"))
                .withActivities(Arrays.asList(new CopyActivity().withName("ExampleCopyActivity")
                    .withInputs(Arrays.asList(new DatasetReference().withReferenceName("exampleDataset").withParameters(
                        mapOf("MyFileName", "examplecontainer.csv", "MyFolderPath", "examplecontainer"))))
                    .withOutputs(Arrays.asList(new DatasetReference().withReferenceName("exampleDataset")
                        .withParameters(mapOf("MyFileName",
                            SerializerFactory.createDefaultManagementSerializerAdapter().deserialize(
                                "{\"type\":\"Expression\",\"value\":\"@item()\"}", Object.class,
                                SerializerEncoding.JSON),
                            "MyFolderPath", "examplecontainer"))))
                    .withSource(new BlobSource()).withSink(new BlobSink()).withDataIntegrationUnits(32)))))
            .withParameters(mapOf("JobId", new ParameterSpecification().withType(ParameterType.STRING),
                "OutputBlobNameList", new ParameterSpecification().withType(ParameterType.ARRAY)))
            .withVariables(mapOf("TestVariableArray", new VariableSpecification().withType(VariableType.ARRAY)))
            .withRunDimensions(mapOf("JobId",
                SerializerFactory.createDefaultManagementSerializerAdapter().deserialize(
                    "{\"type\":\"Expression\",\"value\":\"@pipeline().parameters.JobId\"}", Object.class,
                    SerializerEncoding.JSON)))
            .withPolicy(new PipelinePolicy()
                .withElapsedTimeMetric(new PipelineElapsedTimeMetricPolicy().withDuration("0.00:10:00")))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.datafactory import DataFactoryManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-datafactory
# USAGE
    python pipelines_create.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = DataFactoryManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="12345678-1234-1234-1234-12345678abc",
    )

    response = client.pipelines.create_or_update(
        resource_group_name="exampleResourceGroup",
        factory_name="exampleFactoryName",
        pipeline_name="examplePipeline",
        pipeline={
            "properties": {
                "activities": [
                    {
                        "name": "ExampleForeachActivity",
                        "type": "ForEach",
                        "typeProperties": {
                            "activities": [
                                {
                                    "inputs": [
                                        {
                                            "parameters": {
                                                "MyFileName": "examplecontainer.csv",
                                                "MyFolderPath": "examplecontainer",
                                            },
                                            "referenceName": "exampleDataset",
                                            "type": "DatasetReference",
                                        }
                                    ],
                                    "name": "ExampleCopyActivity",
                                    "outputs": [
                                        {
                                            "parameters": {
                                                "MyFileName": {"type": "Expression", "value": "@item()"},
                                                "MyFolderPath": "examplecontainer",
                                            },
                                            "referenceName": "exampleDataset",
                                            "type": "DatasetReference",
                                        }
                                    ],
                                    "type": "Copy",
                                    "typeProperties": {
                                        "dataIntegrationUnits": 32,
                                        "sink": {"type": "BlobSink"},
                                        "source": {"type": "BlobSource"},
                                    },
                                }
                            ],
                            "isSequential": True,
                            "items": {"type": "Expression", "value": "@pipeline().parameters.OutputBlobNameList"},
                        },
                    }
                ],
                "parameters": {"JobId": {"type": "String"}, "OutputBlobNameList": {"type": "Array"}},
                "policy": {"elapsedTimeMetric": {"duration": "0.00:10:00"}},
                "runDimensions": {"JobId": {"type": "Expression", "value": "@pipeline().parameters.JobId"}},
                "variables": {"TestVariableArray": {"type": "Array"}},
            }
        },
    )
    print(response)


# x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Create.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armdatafactory_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/datafactory/armdatafactory/v9"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/ab04533261eff228f28e08900445d0edef3eb70c/specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Create.json
func ExamplePipelinesClient_CreateOrUpdate_pipelinesCreate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armdatafactory.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewPipelinesClient().CreateOrUpdate(ctx, "exampleResourceGroup", "exampleFactoryName", "examplePipeline", armdatafactory.PipelineResource{
		Properties: &armdatafactory.Pipeline{
			Activities: []armdatafactory.ActivityClassification{
				&armdatafactory.ForEachActivity{
					Name: to.Ptr("ExampleForeachActivity"),
					Type: to.Ptr("ForEach"),
					TypeProperties: &armdatafactory.ForEachActivityTypeProperties{
						Activities: []armdatafactory.ActivityClassification{
							&armdatafactory.CopyActivity{
								Name: to.Ptr("ExampleCopyActivity"),
								Type: to.Ptr("Copy"),
								Inputs: []*armdatafactory.DatasetReference{
									{
										Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
										Parameters: map[string]any{
											"MyFileName":   "examplecontainer.csv",
											"MyFolderPath": "examplecontainer",
										},
										ReferenceName: to.Ptr("exampleDataset"),
									}},
								Outputs: []*armdatafactory.DatasetReference{
									{
										Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
										Parameters: map[string]any{
											"MyFileName": map[string]any{
												"type":  "Expression",
												"value": "@item()",
											},
											"MyFolderPath": "examplecontainer",
										},
										ReferenceName: to.Ptr("exampleDataset"),
									}},
								TypeProperties: &armdatafactory.CopyActivityTypeProperties{
									DataIntegrationUnits: float64(32),
									Sink: &armdatafactory.BlobSink{
										Type: to.Ptr("BlobSink"),
									},
									Source: &armdatafactory.BlobSource{
										Type: to.Ptr("BlobSource"),
									},
								},
							}},
						IsSequential: to.Ptr(true),
						Items: &armdatafactory.Expression{
							Type:  to.Ptr(armdatafactory.ExpressionTypeExpression),
							Value: to.Ptr("@pipeline().parameters.OutputBlobNameList"),
						},
					},
				}},
			Parameters: map[string]*armdatafactory.ParameterSpecification{
				"JobId": {
					Type: to.Ptr(armdatafactory.ParameterTypeString),
				},
				"OutputBlobNameList": {
					Type: to.Ptr(armdatafactory.ParameterTypeArray),
				},
			},
			Policy: &armdatafactory.PipelinePolicy{
				ElapsedTimeMetric: &armdatafactory.PipelineElapsedTimeMetricPolicy{
					Duration: "0.00:10:00",
				},
			},
			RunDimensions: map[string]any{
				"JobId": map[string]any{
					"type":  "Expression",
					"value": "@pipeline().parameters.JobId",
				},
			},
			Variables: map[string]*armdatafactory.VariableSpecification{
				"TestVariableArray": {
					Type: to.Ptr(armdatafactory.VariableTypeArray),
				},
			},
		},
	}, &armdatafactory.PipelinesClientCreateOrUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.PipelineResource = armdatafactory.PipelineResource{
	// 	Name: to.Ptr("examplePipeline"),
	// 	Type: to.Ptr("Microsoft.DataFactory/factories/pipelines"),
	// 	Etag: to.Ptr("0a0069d4-0000-0000-0000-5b245bd50000"),
	// 	ID: to.Ptr("/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline"),
	// 	Properties: &armdatafactory.Pipeline{
	// 		Activities: []armdatafactory.ActivityClassification{
	// 			&armdatafactory.ForEachActivity{
	// 				Name: to.Ptr("ExampleForeachActivity"),
	// 				Type: to.Ptr("ForEach"),
	// 				TypeProperties: &armdatafactory.ForEachActivityTypeProperties{
	// 					Activities: []armdatafactory.ActivityClassification{
	// 						&armdatafactory.CopyActivity{
	// 							Name: to.Ptr("ExampleCopyActivity"),
	// 							Type: to.Ptr("Copy"),
	// 							Inputs: []*armdatafactory.DatasetReference{
	// 								{
	// 									Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
	// 									Parameters: map[string]any{
	// 										"MyFileName": "examplecontainer.csv",
	// 										"MyFolderPath": "examplecontainer",
	// 									},
	// 									ReferenceName: to.Ptr("exampleDataset"),
	// 							}},
	// 							Outputs: []*armdatafactory.DatasetReference{
	// 								{
	// 									Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
	// 									Parameters: map[string]any{
	// 										"MyFileName": map[string]any{
	// 											"type": "Expression",
	// 											"value": "@item()",
	// 										},
	// 										"MyFolderPath": "examplecontainer",
	// 									},
	// 									ReferenceName: to.Ptr("exampleDataset"),
	// 							}},
	// 							TypeProperties: &armdatafactory.CopyActivityTypeProperties{
	// 								DataIntegrationUnits: float64(32),
	// 								Sink: &armdatafactory.BlobSink{
	// 									Type: to.Ptr("BlobSink"),
	// 								},
	// 								Source: &armdatafactory.BlobSource{
	// 									Type: to.Ptr("BlobSource"),
	// 								},
	// 							},
	// 					}},
	// 					IsSequential: to.Ptr(true),
	// 					Items: &armdatafactory.Expression{
	// 						Type: to.Ptr(armdatafactory.ExpressionTypeExpression),
	// 						Value: to.Ptr("@pipeline().parameters.OutputBlobNameList"),
	// 					},
	// 				},
	// 		}},
	// 		Parameters: map[string]*armdatafactory.ParameterSpecification{
	// 			"JobId": &armdatafactory.ParameterSpecification{
	// 				Type: to.Ptr(armdatafactory.ParameterTypeString),
	// 			},
	// 			"OutputBlobNameList": &armdatafactory.ParameterSpecification{
	// 				Type: to.Ptr(armdatafactory.ParameterTypeArray),
	// 			},
	// 		},
	// 		RunDimensions: map[string]any{
	// 			"JobId": map[string]any{
	// 				"type": "Expression",
	// 				"value": "@pipeline().parameters.JobId",
	// 			},
	// 		},
	// 		Variables: map[string]*armdatafactory.VariableSpecification{
	// 			"TestVariableArray": &armdatafactory.VariableSpecification{
	// 				Type: to.Ptr(armdatafactory.VariableTypeArray),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { DataFactoryManagementClient } = require("@azure/arm-datafactory");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates or updates a pipeline.
 *
 * @summary Creates or updates a pipeline.
 * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Create.json
 */
async function pipelinesCreate() {
  const subscriptionId =
    process.env["DATAFACTORY_SUBSCRIPTION_ID"] || "12345678-1234-1234-1234-12345678abc";
  const resourceGroupName = process.env["DATAFACTORY_RESOURCE_GROUP"] || "exampleResourceGroup";
  const factoryName = "exampleFactoryName";
  const pipelineName = "examplePipeline";
  const pipeline = {
    activities: [
      {
        name: "ExampleForeachActivity",
        type: "ForEach",
        activities: [
          {
            name: "ExampleCopyActivity",
            type: "Copy",
            dataIntegrationUnits: 32,
            inputs: [
              {
                type: "DatasetReference",
                parameters: {
                  myFileName: "examplecontainer.csv",
                  myFolderPath: "examplecontainer",
                },
                referenceName: "exampleDataset",
              },
            ],
            outputs: [
              {
                type: "DatasetReference",
                parameters: {
                  myFileName: { type: "Expression", value: "@item()" },
                  myFolderPath: "examplecontainer",
                },
                referenceName: "exampleDataset",
              },
            ],
            sink: { type: "BlobSink" },
            source: { type: "BlobSource" },
          },
        ],
        isSequential: true,
        items: {
          type: "Expression",
          value: "@pipeline().parameters.OutputBlobNameList",
        },
      },
    ],
    parameters: {
      jobId: { type: "String" },
      outputBlobNameList: { type: "Array" },
    },
    policy: { elapsedTimeMetric: { duration: "0.00:10:00" } },
    runDimensions: {
      jobId: { type: "Expression", value: "@pipeline().parameters.JobId" },
    },
    variables: { testVariableArray: { type: "Array" } },
  };
  const credential = new DefaultAzureCredential();
  const client = new DataFactoryManagementClient(credential, subscriptionId);
  const result = await client.pipelines.createOrUpdate(
    resourceGroupName,
    factoryName,
    pipelineName,
    pipeline,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.DataFactory.Models;
using Azure.ResourceManager.DataFactory;

// Generated from example definition: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Create.json
// this example is just showing the usage of "Pipelines_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this DataFactoryResource created on azure
// for more information of creating DataFactoryResource, please refer to the document of DataFactoryResource
string subscriptionId = "12345678-1234-1234-1234-12345678abc";
string resourceGroupName = "exampleResourceGroup";
string factoryName = "exampleFactoryName";
ResourceIdentifier dataFactoryResourceId = DataFactoryResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, factoryName);
DataFactoryResource dataFactory = client.GetDataFactoryResource(dataFactoryResourceId);

// get the collection of this DataFactoryPipelineResource
DataFactoryPipelineCollection collection = dataFactory.GetDataFactoryPipelines();

// invoke the operation
string pipelineName = "examplePipeline";
DataFactoryPipelineData data = new DataFactoryPipelineData()
{
    Activities =
    {
    new ForEachActivity("ExampleForeachActivity",new DataFactoryExpression(DataFactoryExpressionType.Expression,"@pipeline().parameters.OutputBlobNameList"),new PipelineActivity[]
    {
    new CopyActivity("ExampleCopyActivity",new DataFactoryBlobSource(),new DataFactoryBlobSink())
    {
    Inputs =
    {
    new DatasetReference(DatasetReferenceType.DatasetReference,"exampleDataset")
    {
    Parameters =
    {
    ["MyFileName"] = BinaryData.FromString("\"examplecontainer.csv\""),
    ["MyFolderPath"] = BinaryData.FromString("\"examplecontainer\""),
    },
    }
    },
    Outputs =
    {
    new DatasetReference(DatasetReferenceType.DatasetReference,"exampleDataset")
    {
    Parameters =
    {
    ["MyFileName"] = BinaryData.FromObjectAsJson(new Dictionary<string, object>()
    {
    ["type"] = "Expression",
    ["value"] = "@item()"}),
    ["MyFolderPath"] = BinaryData.FromString("\"examplecontainer\""),
    },
    }
    },
    DataIntegrationUnits = 32,
    }
    })
    {
    IsSequential = true,
    }
    },
    Parameters =
    {
    ["JobId"] = new EntityParameterSpecification(EntityParameterType.String),
    ["OutputBlobNameList"] = new EntityParameterSpecification(EntityParameterType.Array),
    },
    Variables =
    {
    ["TestVariableArray"] = new PipelineVariableSpecification(PipelineVariableType.Array),
    },
    RunDimensions =
    {
    ["JobId"] = BinaryData.FromObjectAsJson(new Dictionary<string, object>()
    {
    ["type"] = "Expression",
    ["value"] = "@pipeline().parameters.JobId"}),
    },
    ElapsedTimeMetricDuration = BinaryData.FromString("\"0.00:10:00\""),
};
ArmOperation<DataFactoryPipelineResource> lro = await collection.CreateOrUpdateAsync(WaitUntil.Completed, pipelineName, data);
DataFactoryPipelineResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
DataFactoryPipelineData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Exemple de réponse

Code d’état:

200

Date: Sat, 16 Jun 2018 00:37:41 GMT
X-Content-Type-Options: nosniff
x-ms-ratelimit-remaining-subscription-writes: 1192
x-ms-request-id: e4c589b7-a9fe-4c28-981c-3855ec27d264
x-ms-correlation-request-id: e4c589b7-a9fe-4c28-981c-3855ec27d264

{
  "id": "/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline",
  "name": "examplePipeline",
  "type": "Microsoft.DataFactory/factories/pipelines",
  "properties": {
    "activities": [
      {
        "type": "ForEach",
        "typeProperties": {
          "isSequential": true,
          "items": {
            "value": "@pipeline().parameters.OutputBlobNameList",
            "type": "Expression"
          },
          "activities": [
            {
              "type": "Copy",
              "typeProperties": {
                "source": {
                  "type": "BlobSource"
                },
                "sink": {
                  "type": "BlobSink"
                },
                "dataIntegrationUnits": 32
              },
              "inputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": "examplecontainer.csv"
                  },
                  "type": "DatasetReference"
                }
              ],
              "outputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": {
                      "value": "@item()",
                      "type": "Expression"
                    }
                  },
                  "type": "DatasetReference"
                }
              ],
              "name": "ExampleCopyActivity"
            }
          ]
        },
        "name": "ExampleForeachActivity"
      }
    ],
    "parameters": {
      "OutputBlobNameList": {
        "type": "Array"
      },
      "JobId": {
        "type": "String"
      }
    },
    "variables": {
      "TestVariableArray": {
        "type": "Array"
      }
    },
    "runDimensions": {
      "JobId": {
        "value": "@pipeline().parameters.JobId",
        "type": "Expression"
      }
    }
  },
  "etag": "0a0069d4-0000-0000-0000-5b245bd50000"
}

Pipelines_Update

Exemple de requête

HTTP

PUT https://management.azure.com/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline?api-version=2018-06-01

{
  "properties": {
    "description": "Example description",
    "activities": [
      {
        "type": "ForEach",
        "typeProperties": {
          "isSequential": true,
          "items": {
            "value": "@pipeline().parameters.OutputBlobNameList",
            "type": "Expression"
          },
          "activities": [
            {
              "type": "Copy",
              "typeProperties": {
                "source": {
                  "type": "BlobSource"
                },
                "sink": {
                  "type": "BlobSink"
                },
                "dataIntegrationUnits": 32
              },
              "inputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": "examplecontainer.csv"
                  },
                  "type": "DatasetReference"
                }
              ],
              "outputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": {
                      "value": "@item()",
                      "type": "Expression"
                    }
                  },
                  "type": "DatasetReference"
                }
              ],
              "name": "ExampleCopyActivity"
            }
          ]
        },
        "name": "ExampleForeachActivity"
      }
    ],
    "parameters": {
      "OutputBlobNameList": {
        "type": "Array"
      }
    },
    "policy": {
      "elapsedTimeMetric": {
        "duration": "0.00:10:00"
      }
    }
  }
}

Java

import com.azure.core.management.serializer.SerializerFactory;
import com.azure.core.util.serializer.SerializerEncoding;
import com.azure.resourcemanager.datafactory.models.BlobSink;
import com.azure.resourcemanager.datafactory.models.BlobSource;
import com.azure.resourcemanager.datafactory.models.CopyActivity;
import com.azure.resourcemanager.datafactory.models.DatasetReference;
import com.azure.resourcemanager.datafactory.models.Expression;
import com.azure.resourcemanager.datafactory.models.ForEachActivity;
import com.azure.resourcemanager.datafactory.models.ParameterSpecification;
import com.azure.resourcemanager.datafactory.models.ParameterType;
import com.azure.resourcemanager.datafactory.models.PipelineElapsedTimeMetricPolicy;
import com.azure.resourcemanager.datafactory.models.PipelinePolicy;
import com.azure.resourcemanager.datafactory.models.PipelineResource;
import java.io.IOException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Pipelines CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Update.json
     */
    /**
     * Sample code: Pipelines_Update.
     * 
     * @param manager Entry point to DataFactoryManager.
     */
    public static void pipelinesUpdate(com.azure.resourcemanager.datafactory.DataFactoryManager manager)
        throws IOException {
        PipelineResource resource = manager.pipelines().getWithResponse("exampleResourceGroup", "exampleFactoryName",
            "examplePipeline", null, com.azure.core.util.Context.NONE).getValue();
        resource.update().withDescription("Example description").withActivities(Arrays.asList(new ForEachActivity()
            .withName("ExampleForeachActivity").withIsSequential(true)
            .withItems(new Expression().withValue("@pipeline().parameters.OutputBlobNameList"))
            .withActivities(Arrays.asList(new CopyActivity().withName("ExampleCopyActivity")
                .withInputs(Arrays.asList(new DatasetReference().withReferenceName("exampleDataset")
                    .withParameters(mapOf("MyFileName", "examplecontainer.csv", "MyFolderPath", "examplecontainer"))))
                .withOutputs(Arrays.asList(new DatasetReference().withReferenceName("exampleDataset")
                    .withParameters(mapOf("MyFileName",
                        SerializerFactory.createDefaultManagementSerializerAdapter().deserialize(
                            "{\"type\":\"Expression\",\"value\":\"@item()\"}", Object.class, SerializerEncoding.JSON),
                        "MyFolderPath", "examplecontainer"))))
                .withSource(new BlobSource()).withSink(new BlobSink()).withDataIntegrationUnits(32)))))
            .withParameters(mapOf("OutputBlobNameList", new ParameterSpecification().withType(ParameterType.ARRAY)))
            .withPolicy(new PipelinePolicy()
                .withElapsedTimeMetric(new PipelineElapsedTimeMetricPolicy().withDuration("0.00:10:00")))
            .apply();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.datafactory import DataFactoryManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-datafactory
# USAGE
    python pipelines_update.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = DataFactoryManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="12345678-1234-1234-1234-12345678abc",
    )

    response = client.pipelines.create_or_update(
        resource_group_name="exampleResourceGroup",
        factory_name="exampleFactoryName",
        pipeline_name="examplePipeline",
        pipeline={
            "properties": {
                "activities": [
                    {
                        "name": "ExampleForeachActivity",
                        "type": "ForEach",
                        "typeProperties": {
                            "activities": [
                                {
                                    "inputs": [
                                        {
                                            "parameters": {
                                                "MyFileName": "examplecontainer.csv",
                                                "MyFolderPath": "examplecontainer",
                                            },
                                            "referenceName": "exampleDataset",
                                            "type": "DatasetReference",
                                        }
                                    ],
                                    "name": "ExampleCopyActivity",
                                    "outputs": [
                                        {
                                            "parameters": {
                                                "MyFileName": {"type": "Expression", "value": "@item()"},
                                                "MyFolderPath": "examplecontainer",
                                            },
                                            "referenceName": "exampleDataset",
                                            "type": "DatasetReference",
                                        }
                                    ],
                                    "type": "Copy",
                                    "typeProperties": {
                                        "dataIntegrationUnits": 32,
                                        "sink": {"type": "BlobSink"},
                                        "source": {"type": "BlobSource"},
                                    },
                                }
                            ],
                            "isSequential": True,
                            "items": {"type": "Expression", "value": "@pipeline().parameters.OutputBlobNameList"},
                        },
                    }
                ],
                "description": "Example description",
                "parameters": {"OutputBlobNameList": {"type": "Array"}},
                "policy": {"elapsedTimeMetric": {"duration": "0.00:10:00"}},
            }
        },
    )
    print(response)


# x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Update.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armdatafactory_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/datafactory/armdatafactory/v9"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/ab04533261eff228f28e08900445d0edef3eb70c/specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Update.json
func ExamplePipelinesClient_CreateOrUpdate_pipelinesUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armdatafactory.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewPipelinesClient().CreateOrUpdate(ctx, "exampleResourceGroup", "exampleFactoryName", "examplePipeline", armdatafactory.PipelineResource{
		Properties: &armdatafactory.Pipeline{
			Description: to.Ptr("Example description"),
			Activities: []armdatafactory.ActivityClassification{
				&armdatafactory.ForEachActivity{
					Name: to.Ptr("ExampleForeachActivity"),
					Type: to.Ptr("ForEach"),
					TypeProperties: &armdatafactory.ForEachActivityTypeProperties{
						Activities: []armdatafactory.ActivityClassification{
							&armdatafactory.CopyActivity{
								Name: to.Ptr("ExampleCopyActivity"),
								Type: to.Ptr("Copy"),
								Inputs: []*armdatafactory.DatasetReference{
									{
										Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
										Parameters: map[string]any{
											"MyFileName":   "examplecontainer.csv",
											"MyFolderPath": "examplecontainer",
										},
										ReferenceName: to.Ptr("exampleDataset"),
									}},
								Outputs: []*armdatafactory.DatasetReference{
									{
										Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
										Parameters: map[string]any{
											"MyFileName": map[string]any{
												"type":  "Expression",
												"value": "@item()",
											},
											"MyFolderPath": "examplecontainer",
										},
										ReferenceName: to.Ptr("exampleDataset"),
									}},
								TypeProperties: &armdatafactory.CopyActivityTypeProperties{
									DataIntegrationUnits: float64(32),
									Sink: &armdatafactory.BlobSink{
										Type: to.Ptr("BlobSink"),
									},
									Source: &armdatafactory.BlobSource{
										Type: to.Ptr("BlobSource"),
									},
								},
							}},
						IsSequential: to.Ptr(true),
						Items: &armdatafactory.Expression{
							Type:  to.Ptr(armdatafactory.ExpressionTypeExpression),
							Value: to.Ptr("@pipeline().parameters.OutputBlobNameList"),
						},
					},
				}},
			Parameters: map[string]*armdatafactory.ParameterSpecification{
				"OutputBlobNameList": {
					Type: to.Ptr(armdatafactory.ParameterTypeArray),
				},
			},
			Policy: &armdatafactory.PipelinePolicy{
				ElapsedTimeMetric: &armdatafactory.PipelineElapsedTimeMetricPolicy{
					Duration: "0.00:10:00",
				},
			},
		},
	}, &armdatafactory.PipelinesClientCreateOrUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.PipelineResource = armdatafactory.PipelineResource{
	// 	Name: to.Ptr("examplePipeline"),
	// 	Type: to.Ptr("Microsoft.DataFactory/factories/pipelines"),
	// 	Etag: to.Ptr("0a006cd4-0000-0000-0000-5b245bd60000"),
	// 	ID: to.Ptr("/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline"),
	// 	Properties: &armdatafactory.Pipeline{
	// 		Description: to.Ptr("Example description"),
	// 		Activities: []armdatafactory.ActivityClassification{
	// 			&armdatafactory.ForEachActivity{
	// 				Name: to.Ptr("ExampleForeachActivity"),
	// 				Type: to.Ptr("ForEach"),
	// 				TypeProperties: &armdatafactory.ForEachActivityTypeProperties{
	// 					Activities: []armdatafactory.ActivityClassification{
	// 						&armdatafactory.CopyActivity{
	// 							Name: to.Ptr("ExampleCopyActivity"),
	// 							Type: to.Ptr("Copy"),
	// 							Inputs: []*armdatafactory.DatasetReference{
	// 								{
	// 									Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
	// 									Parameters: map[string]any{
	// 										"MyFileName": "examplecontainer.csv",
	// 										"MyFolderPath": "examplecontainer",
	// 									},
	// 									ReferenceName: to.Ptr("exampleDataset"),
	// 							}},
	// 							Outputs: []*armdatafactory.DatasetReference{
	// 								{
	// 									Type: to.Ptr(armdatafactory.DatasetReferenceTypeDatasetReference),
	// 									Parameters: map[string]any{
	// 										"MyFileName": map[string]any{
	// 											"type": "Expression",
	// 											"value": "@item()",
	// 										},
	// 										"MyFolderPath": "examplecontainer",
	// 									},
	// 									ReferenceName: to.Ptr("exampleDataset"),
	// 							}},
	// 							TypeProperties: &armdatafactory.CopyActivityTypeProperties{
	// 								DataIntegrationUnits: float64(32),
	// 								Sink: &armdatafactory.BlobSink{
	// 									Type: to.Ptr("BlobSink"),
	// 								},
	// 								Source: &armdatafactory.BlobSource{
	// 									Type: to.Ptr("BlobSource"),
	// 								},
	// 							},
	// 					}},
	// 					IsSequential: to.Ptr(true),
	// 					Items: &armdatafactory.Expression{
	// 						Type: to.Ptr(armdatafactory.ExpressionTypeExpression),
	// 						Value: to.Ptr("@pipeline().parameters.OutputBlobNameList"),
	// 					},
	// 				},
	// 		}},
	// 		Parameters: map[string]*armdatafactory.ParameterSpecification{
	// 			"OutputBlobNameList": &armdatafactory.ParameterSpecification{
	// 				Type: to.Ptr(armdatafactory.ParameterTypeArray),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { DataFactoryManagementClient } = require("@azure/arm-datafactory");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates or updates a pipeline.
 *
 * @summary Creates or updates a pipeline.
 * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Update.json
 */
async function pipelinesUpdate() {
  const subscriptionId =
    process.env["DATAFACTORY_SUBSCRIPTION_ID"] || "12345678-1234-1234-1234-12345678abc";
  const resourceGroupName = process.env["DATAFACTORY_RESOURCE_GROUP"] || "exampleResourceGroup";
  const factoryName = "exampleFactoryName";
  const pipelineName = "examplePipeline";
  const pipeline = {
    description: "Example description",
    activities: [
      {
        name: "ExampleForeachActivity",
        type: "ForEach",
        activities: [
          {
            name: "ExampleCopyActivity",
            type: "Copy",
            dataIntegrationUnits: 32,
            inputs: [
              {
                type: "DatasetReference",
                parameters: {
                  myFileName: "examplecontainer.csv",
                  myFolderPath: "examplecontainer",
                },
                referenceName: "exampleDataset",
              },
            ],
            outputs: [
              {
                type: "DatasetReference",
                parameters: {
                  myFileName: { type: "Expression", value: "@item()" },
                  myFolderPath: "examplecontainer",
                },
                referenceName: "exampleDataset",
              },
            ],
            sink: { type: "BlobSink" },
            source: { type: "BlobSource" },
          },
        ],
        isSequential: true,
        items: {
          type: "Expression",
          value: "@pipeline().parameters.OutputBlobNameList",
        },
      },
    ],
    parameters: { outputBlobNameList: { type: "Array" } },
    policy: { elapsedTimeMetric: { duration: "0.00:10:00" } },
  };
  const credential = new DefaultAzureCredential();
  const client = new DataFactoryManagementClient(credential, subscriptionId);
  const result = await client.pipelines.createOrUpdate(
    resourceGroupName,
    factoryName,
    pipelineName,
    pipeline,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.DataFactory.Models;
using Azure.ResourceManager.DataFactory;

// Generated from example definition: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Pipelines_Update.json
// this example is just showing the usage of "Pipelines_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this DataFactoryResource created on azure
// for more information of creating DataFactoryResource, please refer to the document of DataFactoryResource
string subscriptionId = "12345678-1234-1234-1234-12345678abc";
string resourceGroupName = "exampleResourceGroup";
string factoryName = "exampleFactoryName";
ResourceIdentifier dataFactoryResourceId = DataFactoryResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, factoryName);
DataFactoryResource dataFactory = client.GetDataFactoryResource(dataFactoryResourceId);

// get the collection of this DataFactoryPipelineResource
DataFactoryPipelineCollection collection = dataFactory.GetDataFactoryPipelines();

// invoke the operation
string pipelineName = "examplePipeline";
DataFactoryPipelineData data = new DataFactoryPipelineData()
{
    Description = "Example description",
    Activities =
    {
    new ForEachActivity("ExampleForeachActivity",new DataFactoryExpression(DataFactoryExpressionType.Expression,"@pipeline().parameters.OutputBlobNameList"),new PipelineActivity[]
    {
    new CopyActivity("ExampleCopyActivity",new DataFactoryBlobSource(),new DataFactoryBlobSink())
    {
    Inputs =
    {
    new DatasetReference(DatasetReferenceType.DatasetReference,"exampleDataset")
    {
    Parameters =
    {
    ["MyFileName"] = BinaryData.FromString("\"examplecontainer.csv\""),
    ["MyFolderPath"] = BinaryData.FromString("\"examplecontainer\""),
    },
    }
    },
    Outputs =
    {
    new DatasetReference(DatasetReferenceType.DatasetReference,"exampleDataset")
    {
    Parameters =
    {
    ["MyFileName"] = BinaryData.FromObjectAsJson(new Dictionary<string, object>()
    {
    ["type"] = "Expression",
    ["value"] = "@item()"}),
    ["MyFolderPath"] = BinaryData.FromString("\"examplecontainer\""),
    },
    }
    },
    DataIntegrationUnits = 32,
    }
    })
    {
    IsSequential = true,
    }
    },
    Parameters =
    {
    ["OutputBlobNameList"] = new EntityParameterSpecification(EntityParameterType.Array),
    },
    ElapsedTimeMetricDuration = BinaryData.FromString("\"0.00:10:00\""),
};
ArmOperation<DataFactoryPipelineResource> lro = await collection.CreateOrUpdateAsync(WaitUntil.Completed, pipelineName, data);
DataFactoryPipelineResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
DataFactoryPipelineData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Exemple de réponse

Code d’état:

200

Date: Sat, 16 Jun 2018 00:37:43 GMT
X-Content-Type-Options: nosniff
x-ms-ratelimit-remaining-subscription-writes: 1191
x-ms-request-id: 91a763b0-d944-493f-83fc-e989c8b6e122
x-ms-correlation-request-id: 91a763b0-d944-493f-83fc-e989c8b6e122

{
  "id": "/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelines/examplePipeline",
  "name": "examplePipeline",
  "type": "Microsoft.DataFactory/factories/pipelines",
  "properties": {
    "description": "Example description",
    "activities": [
      {
        "type": "ForEach",
        "typeProperties": {
          "isSequential": true,
          "items": {
            "value": "@pipeline().parameters.OutputBlobNameList",
            "type": "Expression"
          },
          "activities": [
            {
              "type": "Copy",
              "typeProperties": {
                "source": {
                  "type": "BlobSource"
                },
                "sink": {
                  "type": "BlobSink"
                },
                "dataIntegrationUnits": 32
              },
              "inputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": "examplecontainer.csv"
                  },
                  "type": "DatasetReference"
                }
              ],
              "outputs": [
                {
                  "referenceName": "exampleDataset",
                  "parameters": {
                    "MyFolderPath": "examplecontainer",
                    "MyFileName": {
                      "value": "@item()",
                      "type": "Expression"
                    }
                  },
                  "type": "DatasetReference"
                }
              ],
              "name": "ExampleCopyActivity"
            }
          ]
        },
        "name": "ExampleForeachActivity"
      }
    ],
    "parameters": {
      "OutputBlobNameList": {
        "type": "Array"
      }
    }
  },
  "etag": "0a006cd4-0000-0000-0000-5b245bd60000"
}

Définitions

Nom	Description
ActivityDependency	Informations sur les dépendances d’activité.
ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
ActivityPolicy	Stratégie d’exécution pour une activité.
ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
AppendVariableActivity	Ajouter une valeur pour une variable de type Array.
AzureDataExplorerCommandActivity	Activité de commande Azure Data Explorer.
AzureFunctionActivity	Activité de fonction Azure.
AzureFunctionActivityMethod	Liste des méthodes HTTP prises en charge par AzureFunctionActivity.
AzureKeyVaultSecretReference	Informations de référence sur les secrets Azure Key Vault.
AzureMLBatchExecutionActivity	Activité d’exécution azure ML Batch.
AzureMLExecutePipelineActivity	Activité de pipeline d’exécution Azure ML.
AzureMLUpdateResourceActivity	Activité de gestion des ressources de mise à jour Azure ML.
AzureMLWebServiceFile	Fichier d’entrée/sortie d’Azure ML WebService
BigDataPoolParametrizationReference	Type de référence du pool Big Data.
BigDataPoolReferenceType	Type de référence du pool Big Data.
CloudError	Objet qui définit la structure d’une réponse d’erreur Azure Data Factory.
Compute	Propriétés de calcul pour l’activité de flux de données.
ConfigurationType	Type de la configuration spark.
ContinuationSettingsReference	Paramètres de continuation pour l’activité d’exécution du flux de données.
ControlActivity	Classe de base pour toutes les activités de contrôle telles que IfCondition, ForEach , Until.
CopyActivity	Activité de copie.
CopyActivityLogSettings	Paramètres du journal d’activité de copie.
CredentialReference	Type de référence d’informations d’identification.
CredentialReferenceType	Type de référence d’informations d’identification.
CustomActivity	Type d’activité personnalisé.
CustomActivityReferenceObject	Objets de référence pour l’activité personnalisée
DatabricksNotebookActivity	Activité DatabricksNotebook.
DatabricksSparkJarActivity	Activité DatabricksSparkJar.
DatabricksSparkPythonActivity	Activité DatabricksSparkPython.
DataFlowReference	Type de référence de flux de données.
DataFlowReferenceType	Type de référence de flux de données.
DataFlowStagingInfo	Informations de préproduction pour l’activité d’exécution du flux de données.
DataLakeAnalyticsUSQLActivity	Activité U-SQL Data Lake Analytics.
DatasetReference	Type de référence de jeu de données.
DeleteActivity	Supprimer l’activité.
DependencyCondition	Match-Condition pour la dépendance.
ExecuteDataFlowActivity	Exécuter l’activité de flux de données.
ExecutePipelineActivity	Exécuter l’activité du pipeline.
ExecutePipelineActivityPolicy	Stratégie d’exécution pour une activité de pipeline d’exécution.
ExecuteSSISPackageActivity	Exécutez l’activité du package SSIS.
ExecuteWranglingDataflowActivity	Exécutez l’activité Power Query.
ExecutionActivity	Classe de base pour toutes les activités d’exécution.
Expression	Définition d’expression Azure Data Factory.
FailActivity	Cette activité échoue dans sa propre étendue et génère un message d’erreur personnalisé et un code d’erreur. Le message d’erreur et le code peuvent être fournis en tant que littéral de chaîne ou en tant qu’expression pouvant être évaluée à une chaîne au moment de l’exécution. L’étendue de l’activité peut être l’ensemble du pipeline ou une activité de contrôle (par exemple, foreach, switch, until), si l’activité d’échec est contenue dans celle-ci.
FilterActivity	Filtrez et retournez les résultats du tableau d’entrée en fonction des conditions.
Folder	Dossier dans lequel se trouve ce pipeline. S’il n’est pas spécifié, le pipeline apparaît au niveau racine.
ForEachActivity	Cette activité est utilisée pour itérer sur une collection et exécuter des activités données.
GetMetadataActivity	Activité permettant d’obtenir les métadonnées du jeu de données
HDInsightActivityDebugInfoOption	Paramètres HDInsightActivityDebugInfoOption à utiliser.
HDInsightHiveActivity	Type d’activité Hive HDInsight.
HDInsightMapReduceActivity	Type d’activité MapReduce HDInsight.
HDInsightPigActivity	Type d’activité Pig HDInsight.
HDInsightSparkActivity	Activité Spark HDInsight.
HDInsightStreamingActivity	Type d’activité de streaming HDInsight.
IfConditionActivity	Cette activité évalue une expression booléenne et exécute les activités sous la propriété ifTrueActivities ou la propriété ifFalseActivities en fonction du résultat de l’expression.
IntegrationRuntimeReference	Type de référence du runtime d’intégration.
LinkedServiceReference	Type de référence de service lié.
LogLocationSettings	Paramètres d’emplacement du journal.
LogSettings	Paramètres du journal.
LogStorageSettings	(Déconseillé. Utilisez les paramètres de stockage des journaux LogSettings.
LookupActivity	Activité de recherche.
NotebookParameter	Paramètre de bloc-notes.
NotebookParameterType	Type de paramètre notebook.
NotebookReferenceType	Type de référence de notebook Synapse.
ParameterSpecification	Définition d’un paramètre unique pour une entité.
ParameterType	Type de paramètre.
PipelineElapsedTimeMetricPolicy	Stratégie de métrique De temps écoulé du pipeline.
PipelinePolicy	Stratégie de pipeline.
PipelineReference	Type de référence de pipeline.
PipelineResource	Type de ressource de pipeline.
PowerQuerySink	Récepteur Power Query.
PowerQuerySinkMapping	Mapper la requête mashup Power Query au ou les jeux de données récepteurs.
RedirectIncompatibleRowSettings	Rediriger les paramètres de ligne incompatibles
ScriptActivity	Type d’activité de script.
ScriptActivityLogDestination	Destination des journaux. Type : chaîne.
ScriptActivityParameter	Paramètres d’un bloc de script.
ScriptActivityParameterDirection	Direction du paramètre.
ScriptActivityParameterType	Type du paramètre.
ScriptActivityScriptBlock	Bloc de scripts de script.
ScriptActivityTypeProperties.LogSettings	Paramètres de journal de l’activité de script.
SecureInputOutputPolicy	Stratégie d’exécution pour une activité qui prend en charge les entrées et sorties sécurisées.
SecureString	Définition de chaîne sécurisée Azure Data Factory. La valeur de chaîne est masquée avec des astérisques '*' pendant les appels d’API Get ou List.
SetVariableActivity	Définissez la valeur d’une variable.
SkipErrorFile	Ignorez le fichier d’erreur.
SparkConfigurationParametrizationReference	Informations de référence sur la configuration Spark.
SparkConfigurationReferenceType	Type de référence de configuration Spark.
SparkJobReferenceType	Type de référence de travail Synapse spark.
SqlServerStoredProcedureActivity	Type d’activité de procédure stockée SQL.
SSISAccessCredential	Informations d’identification d’accès SSIS.
SSISChildPackage	Package enfant incorporé SSIS.
SSISExecutionCredential	Informations d’identification d’exécution du package SSIS.
SSISExecutionParameter	Paramètre d’exécution SSIS.
SSISLogLocation	Emplacement du journal d’exécution du package SSIS
SsisLogLocationType	Type d’emplacement du journal SSIS.
SSISPackageLocation	Emplacement du package SSIS.
SsisPackageLocationType	Type d’emplacement du package SSIS.
SSISPropertyOverride	Remplacement de propriété SSIS.
StagingSettings	Paramètres intermédiaires.
SwitchActivity	Cette activité évalue une expression et exécute des activités sous la propriété cas qui correspondent à l’évaluation d’expression attendue dans la propriété égale.
SwitchCase	Les cas de commutateur avec une valeur et des activités correspondantes.
SynapseNotebookActivity	Exécutez l’activité du notebook Synapse.
SynapseNotebookReference	Type de référence de notebook Synapse.
SynapseSparkJobDefinitionActivity	Exécutez l’activité de travail Spark.
SynapseSparkJobReference	Type de référence de travail Synapse spark.
Type	Type de référence de service lié.
UntilActivity	Cette activité exécute des activités internes jusqu’à ce que les résultats de l’expression booléenne spécifiés soient true ou que le délai d’expiration soit atteint, selon ce qui est antérieur.
UserProperty	Propriété utilisateur.
ValidationActivity	Cette activité vérifie qu’une ressource externe existe.
VariableSpecification	Définition d’une variable unique pour un pipeline.
VariableType	Type de variable.
WaitActivity	Cette activité interrompt l’exécution du pipeline pour l’intervalle spécifié.
WebActivity	Activité web.
WebActivityAuthentication	Propriétés d’authentification d’activité web.
WebActivityMethod	Liste des méthodes HTTP prises en charge par un WebActivity.
WebHookActivity	Activité webHook.
WebHookActivityMethod	Liste des méthodes HTTP prises en charge par une activité WebHook.

ActivityDependency

Informations sur les dépendances d’activité.

Nom	Type	Description
activity	string	Nom de l’activité.
dependencyConditions	DependencyCondition[]	Match-Condition pour la dépendance.

ActivityOnInactiveMarkAs

Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.

Nom	Type	Description
Failed	string
Skipped	string
Succeeded	string

ActivityPolicy

Stratégie d’exécution pour une activité.

Nom	Type	Description
retry	object	Nombre maximal de tentatives ordinaires. La valeur par défaut est 0. Type : entier (ou Expression avec entier resultType), minimum : 0.
retryIntervalInSeconds	integer	Intervalle entre chaque nouvelle tentative (en secondes). La valeur par défaut est de 30 secondes.
secureInput	boolean	Lorsqu’elle est définie sur true, l’entrée de l’activité est considérée comme sécurisée et ne sera pas enregistrée dans la surveillance.
secureOutput	boolean	Lorsqu’elle est définie sur true, la sortie de l’activité est considérée comme sécurisée et ne sera pas journalisée à la surveillance.
timeout	object	Spécifie le délai d’expiration de l’activité à exécuter. Le délai d’expiration par défaut est de 7 jours. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).

ActivityState

État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.

Nom	Type	Description
Active	string
Inactive	string

AppendVariableActivity

Ajouter une valeur pour une variable de type Array.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AppendVariable	Type d’activité.
typeProperties.value	object	Valeur à ajouter. Type : peut être un type de correspondance de valeur statique de l’élément de variable ou expression avec le type de correspondance resultType de l’élément variable
typeProperties.variableName	string	Nom de la variable dont la valeur doit être ajoutée.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureDataExplorerCommandActivity

Activité de commande Azure Data Explorer.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AzureDataExplorerCommand	Type d’activité.
typeProperties.command	object	Commande de contrôle, en fonction de la syntaxe de commande Azure Data Explorer. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.commandTimeout	object	Contrôlez le délai d’expiration de la commande. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9]))..)
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureFunctionActivity

Activité de fonction Azure.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AzureFunctionActivity	Type d’activité.
typeProperties.body	object	Représente la charge utile qui sera envoyée au point de terminaison. Obligatoire pour la méthode POST/PUT, non autorisée pour le type de méthode GET : chaîne (ou expression avec chaîne resultType).
typeProperties.functionName	object	Nom de la fonction que l’activité de fonction Azure appelle. Type : chaîne (ou expression avec chaîne resultType)
typeProperties.headers	object	Représente les en-têtes qui seront envoyés à la demande. Par exemple, pour définir la langue et le type sur une demande : « headers » : { « Accept-Language » : «en-us», « Content-Type » : « application/json » }. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.method	AzureFunctionActivityMethod	Méthode API Rest pour le point de terminaison cible.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureFunctionActivityMethod

Liste des méthodes HTTP prises en charge par AzureFunctionActivity.

Nom	Type	Description
DELETE	string
GET	string
HEAD	string
OPTIONS	string
POST	string
PUT	string
TRACE	string

AzureKeyVaultSecretReference

Informations de référence sur les secrets Azure Key Vault.

Nom	Type	Description
secretName	object	Nom du secret dans Azure Key Vault. Type : chaîne (ou expression avec chaîne resultType).
secretVersion	object	Version du secret dans Azure Key Vault. La valeur par défaut est la dernière version du secret. Type : chaîne (ou expression avec chaîne resultType).
store	LinkedServiceReference	Informations de référence sur le service lié Azure Key Vault.
type	string: AzureKeyVaultSecret	Type du secret.

AzureMLBatchExecutionActivity

Activité d’exécution azure ML Batch.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AzureMLBatchExecution	Type d’activité.
typeProperties.globalParameters	object	Paires clé,valeur à passer au point de terminaison du service d’exécution Azure ML Batch. Les clés doivent correspondre aux noms des paramètres de service web définis dans le service web Azure ML publié. Les valeurs sont transmises dans la propriété GlobalParameters de la demande d’exécution du lot Azure ML.
typeProperties.webServiceInputs	<string,  AzureMLWebServiceFile>	Paires clé,valeur, mappant les noms des entrées de service web du point de terminaison Azure ML aux objets AzureMLWebServiceFile spécifiant les emplacements d’objet blob d’entrée. Ces informations sont transmises dans la propriété WebServiceInputs de la demande d’exécution du lot Azure ML.
typeProperties.webServiceOutputs	<string,  AzureMLWebServiceFile>	Paires clé,valeur, mappant les noms des sorties du service web du point de terminaison Azure ML aux objets AzureMLWebServiceFile spécifiant les emplacements d’objet blob de sortie. Ces informations sont transmises dans la propriété WebServiceOutputs de la demande d’exécution du lot Azure ML.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureMLExecutePipelineActivity

Activité de pipeline d’exécution Azure ML.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AzureMLExecutePipeline	Type d’activité.
typeProperties.continueOnStepFailure	object	Indique s’il faut poursuivre l’exécution d’autres étapes dans PipelineRun en cas d’échec d’une étape. Ces informations seront transmises dans la propriété continueOnStepFailure de la demande d’exécution de pipeline publiée. Type : booléen (ou expression avec resultType booléen).
typeProperties.dataPathAssignments	object	Dictionnaire utilisé pour modifier les affectations de chemins de données sans réentraîner. Les valeurs sont transmises dans la propriété dataPathAssignments de la demande d’exécution de pipeline publiée. Type : objet (ou Expression avec l’objet resultType).
typeProperties.experimentName	object	Nom de l’expérience d’historique des exécutions du pipeline. Ces informations seront transmises dans la propriété ExperimentName de la demande d’exécution de pipeline publiée. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.mlParentRunId	object	ID d’exécution du pipeline azure ML Service parent. Ces informations sont transmises dans la propriété ParentRunId de la demande d’exécution de pipeline publiée. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.mlPipelineEndpointId	object	ID du point de terminaison de pipeline Azure ML publié. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.mlPipelineId	object	ID du pipeline Azure ML publié. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.mlPipelineParameters	object	Paires clé,valeur à passer au point de terminaison de pipeline Azure ML publié. Les clés doivent correspondre aux noms des paramètres de pipeline définis dans le pipeline publié. Les valeurs sont transmises dans la propriété ParameterAssignments de la demande d’exécution de pipeline publiée. Type : objet avec paires clé valeur (ou Expression avec l’objet resultType).
typeProperties.version	object	Version du point de terminaison de pipeline Azure ML publié. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureMLUpdateResourceActivity

Activité de gestion des ressources de mise à jour Azure ML.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: AzureMLUpdateResource	Type d’activité.
typeProperties.trainedModelFilePath	object	Chemin d’accès du fichier relatif dans trainedModelLinkedService pour représenter le fichier .ilearner qui sera chargé par l’opération de mise à jour. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.trainedModelLinkedServiceName	LinkedServiceReference	Nom du service lié Stockage Azure contenant le fichier .ilearner qui sera chargé par l’opération de mise à jour.
typeProperties.trainedModelName	object	Nom du module Model entraîné dans l’expérience de service web à mettre à jour. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

AzureMLWebServiceFile

Fichier d’entrée/sortie d’Azure ML WebService

Nom	Type	Description
filePath	object	Chemin d’accès du fichier relatif, y compris le nom du conteneur, dans le Stockage Blob Azure spécifié par LinkedService. Type : chaîne (ou expression avec chaîne resultType).
linkedServiceName	LinkedServiceReference	Référence à un LinkedService Stockage Azure, où se trouve le fichier d’entrée/sortie d’Azure ML WebService.

BigDataPoolParametrizationReference

Type de référence du pool Big Data.

Nom	Type	Description
referenceName	object	Référencez le nom du pool Big Data. Type : chaîne (ou expression avec chaîne resultType).
type	BigDataPoolReferenceType	Type de référence du pool Big Data.

BigDataPoolReferenceType

Type de référence du pool Big Data.

Nom	Type	Description
BigDataPoolReference	string

CloudError

Objet qui définit la structure d’une réponse d’erreur Azure Data Factory.

Nom	Type	Description
error.code	string	Code d’erreur.
error.details	CloudError[]	Tableau avec des détails d’erreur supplémentaires.
error.message	string	Message d'erreur.
error.target	string	Nom/chemin de propriété dans la requête associée à l’erreur.

Compute

Propriétés de calcul pour l’activité de flux de données.

Nom	Type	Description
computeType	object	Type de calcul du cluster qui exécute le travail de flux de données. Les valeurs possibles sont les suivantes : « Général », « MemoryOptimized », « ComputeOptimized ». Type : chaîne (ou expression avec chaîne resultType)
coreCount	object	Nombre principal du cluster qui exécute le travail de flux de données. Les valeurs prises en charge sont les suivantes : 8, 16, 32, 48, 80, 144 et 272. Type : entier (ou Expression avec entier resultType)

ConfigurationType

Type de la configuration spark.

Nom	Type	Description
Artifact	string
Customized	string
Default	string

ContinuationSettingsReference

Paramètres de continuation pour l’activité d’exécution du flux de données.

Nom	Type	Description
continuationTtlInMinutes	object	Durée de vie de continuation en minutes.
customizedCheckpointKey	object	Clé de point de contrôle personnalisée.
idleCondition	object	Condition d’inactivité.

ControlActivity

Classe de base pour toutes les activités de contrôle telles que IfCondition, ForEach , Until.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Container	Type d’activité.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

CopyActivity

Activité de copie.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
inputs	DatasetReference[]	Liste des entrées de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
outputs	DatasetReference[]	Liste des sorties de l’activité.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Copy	Type d’activité.
typeProperties.dataIntegrationUnits	object	Nombre maximal d’unités d’intégration de données qui peuvent être utilisées pour effectuer ce déplacement de données. Type : entier (ou Expression avec entier resultType), minimum : 0.
typeProperties.enableSkipIncompatibleRow	object	Indique s’il faut ignorer la ligne incompatible. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
typeProperties.enableStaging	object	Spécifie s’il faut copier des données via une préproduction intermédiaire. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
typeProperties.logSettings	LogSettings	Les paramètres de journal doivent être fournis par le client lors de l’activation du journal.
typeProperties.logStorageSettings	LogStorageSettings	(Déconseillé. Utilisez les paramètres de stockage des journaux LogSettings que le client doit fournir lors de l’activation du journal de session.
typeProperties.parallelCopies	object	Nombre maximal de sessions simultanées ouvertes sur la source ou le récepteur pour éviter de surcharger le magasin de données. Type : entier (ou Expression avec entier resultType), minimum : 0.
typeProperties.preserve	object[]	Conservez les règles.
typeProperties.preserveRules	object[]	Conservez les règles.
typeProperties.redirectIncompatibleRowSettings	RedirectIncompatibleRowSettings	Redirigez les paramètres de ligne incompatibles lorsque EnableSkipIncompatibleRow a la valeur true.
typeProperties.sink	CopySink	Récepteur d’activité de copie.
typeProperties.skipErrorFile	SkipErrorFile	Spécifiez la tolérance de panne pour la cohérence des données.
typeProperties.source	CopySource	Source de l’activité de copie.
typeProperties.stagingSettings	StagingSettings	Spécifie les paramètres intermédiaires de préproduction lorsque EnableStaging a la valeur true.
typeProperties.translator	object	Traducteur d’activité de copie. S’il n’est pas spécifié, le traducteur tabulaire est utilisé.
typeProperties.validateDataConsistency	object	Indique s’il faut activer la validation de cohérence des données. Type : booléen (ou expression avec resultType booléen).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

CopyActivityLogSettings

Paramètres du journal d’activité de copie.

Nom	Type	Description
enableReliableLogging	object	Spécifie s’il faut activer la journalisation fiable. Type : booléen (ou expression avec resultType booléen).
logLevel	object	Obtient ou définit le niveau de journal, prise en charge : Informations, Avertissement. Type : chaîne (ou expression avec chaîne resultType).

CredentialReference

Type de référence d’informations d’identification.

Nom	Type	Description
referenceName	string	Nom des informations d’identification de référence.
type	CredentialReferenceType	Type de référence d’informations d’identification.

CredentialReferenceType

Type de référence d’informations d’identification.

Nom	Type	Description
CredentialReference	string

CustomActivity

Type d’activité personnalisé.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Custom	Type d’activité.
typeProperties.autoUserSpecification	object	Niveau d’élévation et étendue pour l’utilisateur, la valeur par défaut est une tâche nonadmin. Type : chaîne (ou expression avec resultType double).
typeProperties.command	object	Commande pour le type d’activité personnalisé : chaîne (ou expression avec chaîne resultType).
typeProperties.extendedProperties	object	Conteneur de propriétés défini par l’utilisateur. Il n’existe aucune restriction sur les clés ou les valeurs qui peuvent être utilisées. L’activité personnalisée spécifiée par l’utilisateur a la responsabilité totale de consommer et d’interpréter le contenu défini.
typeProperties.folderPath	object	Chemin d’accès aux fichiers de ressources Type : chaîne (ou Expression avec chaîne resultType).
typeProperties.referenceObjects	CustomActivityReferenceObject	Objets de référence
typeProperties.resourceLinkedService	LinkedServiceReference	Informations de référence sur le service lié aux ressources.
typeProperties.retentionTimeInDays	object	Durée de rétention des fichiers envoyés pour l’activité personnalisée. Type : double (ou expression avec resultType double).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

CustomActivityReferenceObject

Objets de référence pour l’activité personnalisée

Nom	Type	Description
datasets	DatasetReference[]	Références de jeu de données.
linkedServices	LinkedServiceReference[]	Références de service lié.

DatabricksNotebookActivity

Activité DatabricksNotebook.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: DatabricksNotebook	Type d’activité.
typeProperties.baseParameters	object	Paramètres de base à utiliser pour chaque exécution de ce travail. Si le bloc-notes accepte un paramètre qui n’est pas spécifié, la valeur par défaut du bloc-notes est utilisée.
typeProperties.libraries	object[]	Liste des bibliothèques à installer sur le cluster qui exécutera le travail.
typeProperties.notebookPath	object	Chemin absolu du notebook à exécuter dans l’espace de travail Databricks. Ce chemin doit commencer par une barre oblique. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

DatabricksSparkJarActivity

Activité DatabricksSparkJar.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: DatabricksSparkJar	Type d’activité.
typeProperties.libraries	object[]	Liste des bibliothèques à installer sur le cluster qui exécutera le travail.
typeProperties.mainClassName	object	Nom complet de la classe contenant la méthode principale à exécuter. Cette classe doit être contenue dans un fichier JAR fourni en tant que bibliothèque. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.parameters	object[]	Paramètres qui seront transmis à la méthode principale.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

DatabricksSparkPythonActivity

Activité DatabricksSparkPython.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: DatabricksSparkPython	Type d’activité.
typeProperties.libraries	object[]	Liste des bibliothèques à installer sur le cluster qui exécutera le travail.
typeProperties.parameters	object[]	Paramètres de ligne de commande qui seront transmis au fichier Python.
typeProperties.pythonFile	object	URI du fichier Python à exécuter. Les chemins DBFS sont pris en charge. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

DataFlowReference

Type de référence de flux de données.

Nom	Type	Description
datasetParameters	object	Référencer les paramètres de flux de données à partir du jeu de données.
parameters	object	Paramètres de flux de données
referenceName	string	Nom du flux de données de référence.
type	DataFlowReferenceType	Type de référence de flux de données.

DataFlowReferenceType

Type de référence de flux de données.

Nom	Type	Description
DataFlowReference	string

DataFlowStagingInfo

Informations de préproduction pour l’activité d’exécution du flux de données.

Nom	Type	Description
folderPath	object	Chemin d’accès du dossier pour l’objet blob intermédiaire. Type : chaîne (ou expression avec chaîne resultType)
linkedService	LinkedServiceReference	Informations de référence sur le service lié intermédiaire.

DataLakeAnalyticsUSQLActivity

Activité U-SQL Data Lake Analytics.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: DataLakeAnalyticsU-SQL	Type d’activité.
typeProperties.compilationMode	object	Mode de compilation de U-SQL. Doit être l’une de ces valeurs : Sémantique, Full et SingleBox. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.degreeOfParallelism	object	Nombre maximal de nœuds utilisés simultanément pour exécuter le travail. La valeur par défaut est 1. Type : entier (ou Expression avec entier resultType), minimum : 1.
typeProperties.parameters	object	Paramètres de la requête de travail U-SQL.
typeProperties.priority	object	Détermine les travaux hors de toutes les files d’attente qui doivent être sélectionnés pour s’exécuter en premier. Plus le nombre est faible, plus la priorité est élevée. La valeur par défaut est 1 000. Type : entier (ou Expression avec entier resultType), minimum : 1.
typeProperties.runtimeVersion	object	Version runtime du moteur U-SQL à utiliser. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.scriptLinkedService	LinkedServiceReference	Référence du service lié de script.
typeProperties.scriptPath	object	Chemin d’accès sensible à la casse vers le dossier qui contient le script U-SQL. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

DatasetReference

Type de référence de jeu de données.

Nom	Type	Description
parameters	object	Arguments pour le jeu de données.
referenceName	string	Nom du jeu de données de référence.
type	enum: DatasetReference	Type de référence de jeu de données.

DeleteActivity

Supprimer l’activité.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Delete	Type d’activité.
typeProperties.dataset	DatasetReference	Supprimer la référence du jeu de données d’activité.
typeProperties.enableLogging	object	Indique s’il faut enregistrer des journaux détaillés d’exécution de l’activité de suppression. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
typeProperties.logStorageSettings	LogStorageSettings	Les paramètres de stockage des journaux doivent être fournis lorsque enableLogging a la valeur true.
typeProperties.maxConcurrentConnections	integer	Nombre maximal de connexions simultanées pour connecter la source de données en même temps.
typeProperties.recursive	object	Si la valeur est true, les fichiers ou sous-dossiers sous le chemin du dossier actuel sont supprimés de manière récursive. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
typeProperties.storeSettings	StoreReadSettings	Supprimez les paramètres du magasin d’activités.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

DependencyCondition

Match-Condition pour la dépendance.

Nom	Type	Description
Completed	string
Failed	string
Skipped	string
Succeeded	string

ExecuteDataFlowActivity

Exécuter l’activité de flux de données.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: ExecuteDataFlow	Type d’activité.
typeProperties.compute	Compute	Propriétés de calcul pour l’activité de flux de données.
typeProperties.continuationSettings	ContinuationSettingsReference	Paramètres de continuation pour l’activité d’exécution du flux de données.
typeProperties.continueOnError	object	Poursuivez le paramètre d’erreur utilisé pour l’exécution du flux de données. Permet au traitement de continuer en cas d’échec d’un récepteur. Type : booléen (ou expression avec resultType boolean)
typeProperties.dataFlow	DataFlowReference	Informations de référence sur le flux de données.
typeProperties.integrationRuntime	IntegrationRuntimeReference	Référence du runtime d’intégration.
typeProperties.runConcurrently	object	Paramètre d’exécution simultané utilisé pour l’exécution du flux de données. Permet aux récepteurs avec la même commande d’enregistrement d’être traités simultanément. Type : booléen (ou expression avec resultType boolean)
typeProperties.sourceStagingConcurrency	object	Spécifiez le nombre de préproductions parallèles pour les sources applicables au récepteur. Type : entier (ou Expression avec entier resultType)
typeProperties.staging	DataFlowStagingInfo	Informations de préproduction pour l’activité d’exécution du flux de données.
typeProperties.traceLevel	object	Paramètre de niveau de trace utilisé pour la sortie de surveillance du flux de données. Les valeurs prises en charge sont les suivantes : « grossière », « fine » et « none ». Type : chaîne (ou expression avec chaîne resultType)
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

ExecutePipelineActivity

Exécuter l’activité du pipeline.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ExecutePipelineActivityPolicy	Exécutez la stratégie d’activité de pipeline.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: ExecutePipeline	Type d’activité.
typeProperties.parameters	object	Paramètres de pipeline.
typeProperties.pipeline	PipelineReference	Référence de pipeline.
typeProperties.waitOnCompletion	boolean	Définit si l’exécution de l’activité attend la fin de l’exécution du pipeline dépendant. La valeur par défaut est false.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

ExecutePipelineActivityPolicy

Stratégie d’exécution pour une activité de pipeline d’exécution.

Nom	Type	Description
secureInput	boolean	Lorsqu’elle est définie sur true, l’entrée de l’activité est considérée comme sécurisée et ne sera pas enregistrée dans la surveillance.

ExecuteSSISPackageActivity

Exécutez l’activité du package SSIS.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: ExecuteSSISPackage	Type d’activité.
typeProperties.connectVia	IntegrationRuntimeReference	Référence du runtime d’intégration.
typeProperties.environmentPath	object	Chemin d’accès de l’environnement pour exécuter le package SSIS. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.executionCredential	SSISExecutionCredential	Informations d’identification d’exécution du package.
typeProperties.logLocation	SSISLogLocation	Emplacement du journal d’exécution du package SSIS.
typeProperties.loggingLevel	object	Niveau de journalisation de l’exécution du package SSIS. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.packageConnectionManagers	object	Gestionnaires de connexions au niveau du package pour exécuter le package SSIS.
typeProperties.packageLocation	SSISPackageLocation	Emplacement du package SSIS.
typeProperties.packageParameters	<string,  SSISExecutionParameter>	Paramètres de niveau package pour exécuter le package SSIS.
typeProperties.projectConnectionManagers	object	Gestionnaires de connexions au niveau du projet pour exécuter le package SSIS.
typeProperties.projectParameters	<string,  SSISExecutionParameter>	Paramètres au niveau du projet pour exécuter le package SSIS.
typeProperties.propertyOverrides	<string,  SSISPropertyOverride>	La propriété remplace l’exécution du package SSIS.
typeProperties.runtime	object	Spécifie le runtime pour exécuter le package SSIS. La valeur doit être « x86 » ou « x64 ». Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

ExecuteWranglingDataflowActivity

Exécutez l’activité Power Query.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: ExecuteWranglingDataflow	Type d’activité.
typeProperties.compute	Compute	Propriétés de calcul pour l’activité de flux de données.
typeProperties.continuationSettings	ContinuationSettingsReference	Paramètres de continuation pour l’activité d’exécution du flux de données.
typeProperties.continueOnError	object	Poursuivez le paramètre d’erreur utilisé pour l’exécution du flux de données. Permet au traitement de continuer en cas d’échec d’un récepteur. Type : booléen (ou expression avec resultType boolean)
typeProperties.dataFlow	DataFlowReference	Informations de référence sur le flux de données.
typeProperties.integrationRuntime	IntegrationRuntimeReference	Référence du runtime d’intégration.
typeProperties.queries	PowerQuerySinkMapping[]	Liste des mappages pour la requête mashup Power Query sur des jeux de données récepteurs.
typeProperties.runConcurrently	object	Paramètre d’exécution simultané utilisé pour l’exécution du flux de données. Permet aux récepteurs avec la même commande d’enregistrement d’être traités simultanément. Type : booléen (ou expression avec resultType boolean)
typeProperties.sinks	<string,  PowerQuerySink>	(Déconseillé. Utilisez les requêtes). Liste des récepteurs d’activité Power Query mappés à un queryName.
typeProperties.sourceStagingConcurrency	object	Spécifiez le nombre de préproductions parallèles pour les sources applicables au récepteur. Type : entier (ou Expression avec entier resultType)
typeProperties.staging	DataFlowStagingInfo	Informations de préproduction pour l’activité d’exécution du flux de données.
typeProperties.traceLevel	object	Paramètre de niveau de trace utilisé pour la sortie de surveillance du flux de données. Les valeurs prises en charge sont les suivantes : « grossière », « fine » et « none ». Type : chaîne (ou expression avec chaîne resultType)
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

ExecutionActivity

Classe de base pour toutes les activités d’exécution.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Execution	Type d’activité.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

Expression

Définition d’expression Azure Data Factory.

Nom	Type	Description
type	enum: Expression	Type d’expression.
value	string	Valeur d’expression.

FailActivity

Cette activité échoue dans sa propre étendue et génère un message d’erreur personnalisé et un code d’erreur. Le message d’erreur et le code peuvent être fournis en tant que littéral de chaîne ou en tant qu’expression pouvant être évaluée à une chaîne au moment de l’exécution. L’étendue de l’activité peut être l’ensemble du pipeline ou une activité de contrôle (par exemple, foreach, switch, until), si l’activité d’échec est contenue dans celle-ci.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Fail	Type d’activité.
typeProperties.errorCode	object	Code d’erreur qui catégorise le type d’erreur de l’activité Échec. Il peut s’agir d’un contenu dynamique évalué à une chaîne non vide/vide au moment de l’exécution. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.message	object	Message d’erreur qui s’est produit dans l’activité Échec. Il peut s’agir d’un contenu dynamique évalué à une chaîne non vide/vide au moment de l’exécution. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

FilterActivity

Filtrez et retournez les résultats du tableau d’entrée en fonction des conditions.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Filter	Type d’activité.
typeProperties.condition	Expression	Condition à utiliser pour filtrer l’entrée.
typeProperties.items	Expression	Tableau d’entrée sur lequel le filtre doit être appliqué.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

Folder

Dossier dans lequel se trouve ce pipeline. S’il n’est pas spécifié, le pipeline apparaît au niveau racine.

Nom	Type	Description
name	string	Nom du dossier dans lequel se trouve ce pipeline.

ForEachActivity

Cette activité est utilisée pour itérer sur une collection et exécuter des activités données.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: ForEach	Type d’activité.
typeProperties.activities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter .
typeProperties.batchCount	integer	Nombre de lots à utiliser pour contrôler le nombre d’exécutions parallèles (quand isSequential a la valeur false).
typeProperties.isSequential	boolean	Si la boucle doit être exécutée en séquence ou en parallèle (max. 50)
typeProperties.items	Expression	Collection à itérer.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

GetMetadataActivity

Activité permettant d’obtenir les métadonnées du jeu de données

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: GetMetadata	Type d’activité.
typeProperties.dataset	DatasetReference	Informations de référence sur le jeu de données d’activité GetMetadata.
typeProperties.fieldList	object[]	Champs de métadonnées à obtenir à partir du jeu de données.
typeProperties.formatSettings	FormatReadSettings	Paramètres de format d’activité GetMetadata.
typeProperties.storeSettings	StoreReadSettings	Paramètres du magasin d’activités GetMetadata.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

HDInsightActivityDebugInfoOption

Paramètres HDInsightActivityDebugInfoOption à utiliser.

Nom	Type	Description
Always	string
Failure	string
None	string

HDInsightHiveActivity

Type d’activité Hive HDInsight.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: HDInsightHive	Type d’activité.
typeProperties.arguments	object[]	Arguments spécifiés par l’utilisateur pour HDInsightActivity.
typeProperties.defines	object	Permet à l’utilisateur de spécifier des définitions pour la demande de travail Hive.
typeProperties.getDebugInfo	HDInsightActivityDebugInfoOption	Option d’informations de débogage.
typeProperties.queryTimeout	integer	Valeur du délai d’expiration de la requête (en minutes). Effectif lorsque le cluster HDInsight est avec ESP (Package Sécurité Entreprise)
typeProperties.scriptLinkedService	LinkedServiceReference	Référence du service lié de script.
typeProperties.scriptPath	object	Chemin d’accès du script. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.storageLinkedServices	LinkedServiceReference[]	Références de service lié de stockage.
typeProperties.variables	object	Arguments spécifiés par l’utilisateur sous l’espace de noms hivevar.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

HDInsightMapReduceActivity

Type d’activité MapReduce HDInsight.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: HDInsightMapReduce	Type d’activité.
typeProperties.arguments	object[]	Arguments spécifiés par l’utilisateur pour HDInsightActivity.
typeProperties.className	object	Nom de la classe. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.defines	object	Permet à l’utilisateur de spécifier des définitions pour la demande de travail MapReduce.
typeProperties.getDebugInfo	HDInsightActivityDebugInfoOption	Option d’informations de débogage.
typeProperties.jarFilePath	object	Chemin d’accès jar. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.jarLibs	object[]	Bibliothèques jar.
typeProperties.jarLinkedService	LinkedServiceReference	Informations de référence sur le service lié Jar.
typeProperties.storageLinkedServices	LinkedServiceReference[]	Références de service lié de stockage.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

HDInsightPigActivity

Type d’activité Pig HDInsight.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: HDInsightPig	Type d’activité.
typeProperties.arguments	object	Arguments spécifiés par l’utilisateur pour HDInsightActivity. Type : tableau (ou Expression avec tableau resultType).
typeProperties.defines	object	Permet à l’utilisateur de spécifier des définitions pour la demande de travail Pig.
typeProperties.getDebugInfo	HDInsightActivityDebugInfoOption	Option d’informations de débogage.
typeProperties.scriptLinkedService	LinkedServiceReference	Référence du service lié de script.
typeProperties.scriptPath	object	Chemin d’accès du script. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.storageLinkedServices	LinkedServiceReference[]	Références de service lié de stockage.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

HDInsightSparkActivity

Activité Spark HDInsight.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: HDInsightSpark	Type d’activité.
typeProperties.arguments	object[]	Arguments spécifiés par l’utilisateur sur HDInsightSparkActivity.
typeProperties.className	string	Classe principale Java/Spark de l’application.
typeProperties.entryFilePath	object	Chemin d’accès relatif au dossier racine du code/package à exécuter. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.getDebugInfo	HDInsightActivityDebugInfoOption	Option d’informations de débogage.
typeProperties.proxyUser	object	L’utilisateur doit emprunter l’identité qui exécutera le travail. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.rootPath	object	Chemin d’accès racine dans « sparkJobLinkedService » pour tous les fichiers du travail. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.sparkConfig	object	Propriété de configuration Spark.
typeProperties.sparkJobLinkedService	LinkedServiceReference	Service lié de stockage pour le chargement du fichier d’entrée et des dépendances, ainsi que pour la réception des journaux.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

HDInsightStreamingActivity

Type d’activité de streaming HDInsight.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: HDInsightStreaming	Type d’activité.
typeProperties.arguments	object[]	Arguments spécifiés par l’utilisateur pour HDInsightActivity.
typeProperties.combiner	object	Nom exécutable du combineur. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.commandEnvironment	object[]	Valeurs d’environnement de ligne de commande.
typeProperties.defines	object	Permet à l’utilisateur de spécifier des définitions pour la demande de travail de diffusion en continu.
typeProperties.fileLinkedService	LinkedServiceReference	Référence de service lié où se trouvent les fichiers.
typeProperties.filePaths	object[]	Chemins d’accès aux fichiers de travail de streaming. Il peut s’agir de répertoires.
typeProperties.getDebugInfo	HDInsightActivityDebugInfoOption	Option d’informations de débogage.
typeProperties.input	object	Chemin d’accès de l’objet blob d’entrée. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.mapper	object	Nom exécutable du mappeur. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.output	object	Chemin d’accès de l’objet blob de sortie. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.reducer	object	Nom exécutable du réducteur. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.storageLinkedServices	LinkedServiceReference[]	Références de service lié de stockage.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

IfConditionActivity

Cette activité évalue une expression booléenne et exécute les activités sous la propriété ifTrueActivities ou la propriété ifFalseActivities en fonction du résultat de l’expression.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: IfCondition	Type d’activité.
typeProperties.expression	Expression	Expression qui évaluerait booléen. Cela permet de déterminer le bloc d’activités (ifTrueActivities ou ifFalseActivities) qui seront exécutées.
typeProperties.ifFalseActivities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter si l’expression est évaluée à false. Il s’agit d’une propriété facultative et, si elle n’est pas fournie, l’activité s’arrête sans aucune action.
typeProperties.ifTrueActivities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter si l’expression est évaluée à true. Il s’agit d’une propriété facultative et, si elle n’est pas fournie, l’activité s’arrête sans aucune action.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

IntegrationRuntimeReference

Type de référence du runtime d’intégration.

Nom	Type	Description
parameters	object	Arguments pour le runtime d’intégration.
referenceName	string	Référencer le nom du runtime d’intégration.
type	enum: IntegrationRuntimeReference	Type de runtime d’intégration.

LinkedServiceReference

Type de référence de service lié.

Nom	Type	Description
parameters	object	Arguments pour LinkedService.
referenceName	string	Référencer le nom linkedService.
type	Type	Type de référence de service lié.

LogLocationSettings

Paramètres d’emplacement du journal.

Nom	Type	Description
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié de stockage des journaux.
path	object	Chemin d’accès au stockage pour stocker les journaux d’activité détaillés de l’exécution de l’activité. Type : chaîne (ou expression avec chaîne resultType).

LogSettings

Paramètres du journal.

Nom	Type	Description
copyActivityLogSettings	CopyActivityLogSettings	Spécifie les paramètres du journal d’activité de copie.
enableCopyActivityLog	object	Spécifie s’il faut activer le journal d’activité de copie. Type : booléen (ou expression avec resultType booléen).
logLocationSettings	LogLocationSettings	Les paramètres d’emplacement du journal doivent être fournis par le client lors de l’activation du journal.

LogStorageSettings

(Déconseillé. Utilisez les paramètres de stockage des journaux LogSettings.

Nom	Type	Description
enableReliableLogging	object	Spécifie s’il faut activer la journalisation fiable. Type : booléen (ou expression avec resultType booléen).
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié de stockage des journaux.
logLevel	object	Obtient ou définit le niveau de journal, prise en charge : Informations, Avertissement. Type : chaîne (ou expression avec chaîne resultType).
path	object	Chemin d’accès au stockage pour stocker les journaux d’activité détaillés de l’exécution de l’activité. Type : chaîne (ou expression avec chaîne resultType).

LookupActivity

Activité de recherche.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Lookup	Type d’activité.
typeProperties.dataset	DatasetReference	Référence du jeu de données d’activité de recherche.
typeProperties.firstRowOnly	object	Indique s’il faut retourner la première ligne ou toutes les lignes. La valeur par défaut est true. Type : booléen (ou expression avec resultType booléen).
typeProperties.source	CopySource	Propriétés sources spécifiques au jeu de données, identiques à celles de la source d’activité de copie.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

NotebookParameter

Paramètre de bloc-notes.

Nom	Type	Description
type	NotebookParameterType	Type de paramètre notebook.
value	object	Valeur du paramètre notebook. Type : chaîne (ou expression avec chaîne resultType).

NotebookParameterType

Type de paramètre notebook.

Nom	Type	Description
bool	string
float	string
int	string
string	string

NotebookReferenceType

Type de référence de notebook Synapse.

Nom	Type	Description
NotebookReference	string

ParameterSpecification

Définition d’un paramètre unique pour une entité.

Nom	Type	Description
defaultValue	object	Valeur par défaut du paramètre.
type	ParameterType	Type de paramètre.

ParameterType

Type de paramètre.

Nom	Type	Description
Array	string
Bool	string
Float	string
Int	string
Object	string
SecureString	string
String	string

PipelineElapsedTimeMetricPolicy

Stratégie de métrique De temps écoulé du pipeline.

Nom	Type	Description
duration	object	Valeur TimeSpan, après laquelle une métrique de supervision Azure est déclenchée.

PipelinePolicy

Stratégie de pipeline.

Nom	Type	Description
elapsedTimeMetric	PipelineElapsedTimeMetricPolicy	Stratégie de métrique De temps écoulé du pipeline.

PipelineReference

Type de référence de pipeline.

Nom	Type	Description
name	string	Nom de référence.
referenceName	string	Nom du pipeline de référence.
type	enum: PipelineReference	Type de référence de pipeline.

PipelineResource

Type de ressource de pipeline.

Nom	Type	Description
etag	string	Etag identifie les modifications dans la ressource.
id	string	Identificateur de ressource.
name	string	Nom de la ressource.
properties.activities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités dans le pipeline.
properties.annotations	object[]	Liste des balises qui peuvent être utilisées pour décrire le pipeline.
properties.concurrency	integer	Nombre maximal d’exécutions simultanées pour le pipeline.
properties.description	string	Description du pipeline.
properties.folder	Folder	Dossier dans lequel se trouve ce pipeline. S’il n’est pas spécifié, le pipeline apparaît au niveau racine.
properties.parameters	<string,  ParameterSpecification>	Liste des paramètres du pipeline.
properties.policy	PipelinePolicy	Stratégie de pipeline.
properties.runDimensions	object	Dimensions émises par pipeline.
properties.variables	<string,  VariableSpecification>	Liste des variables pour le pipeline.
type	string	Type de ressource.

PowerQuerySink

Récepteur Power Query.

Nom	Type	Description
dataset	DatasetReference	Informations de référence sur le jeu de données.
description	string	Description de la transformation.
flowlet	DataFlowReference	Informations de référence sur flowlet
linkedService	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de la transformation.
rejectedDataLinkedService	LinkedServiceReference	Informations de référence sur le service lié aux données rejetées.
schemaLinkedService	LinkedServiceReference	Informations de référence sur le service lié au schéma.
script	string	script récepteur.

PowerQuerySinkMapping

Mapper la requête mashup Power Query au ou les jeux de données récepteurs.

Nom	Type	Description
dataflowSinks	PowerQuerySink[]	Liste des récepteurs mappés à la requête mashup Power Query.
queryName	string	Nom de la requête dans le document mashup Power Query.

RedirectIncompatibleRowSettings

Rediriger les paramètres de ligne incompatibles

Nom	Type	Description
linkedServiceName	object	Nom du service lié Stockage Azure, SAP De Stockage ou Azure Data Lake Store utilisé pour rediriger une ligne incompatible. Doit être spécifié si redirectIncompatibleRowSettings est spécifié. Type : chaîne (ou expression avec chaîne resultType).
path	object	Chemin d’accès pour le stockage des données de ligne incompatibles de redirection. Type : chaîne (ou expression avec chaîne resultType).

ScriptActivity

Type d’activité de script.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Script	Type d’activité.
typeProperties.logSettings	ScriptActivityTypeProperties.LogSettings	Paramètres de journal de l’activité de script.
typeProperties.returnMultistatementResult	object	Permet de récupérer des jeux de résultats à partir de plusieurs instructions SQL et du nombre de lignes affectées par l’instruction DML. Connecteur pris en charge : SnowflakeV2. Type : booléen (ou expression avec resultType booléen).
typeProperties.scriptBlockExecutionTimeout	object	Délai d’expiration de l’exécution de ScriptBlock. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).
typeProperties.scripts	ScriptActivityScriptBlock[]	Tableau de blocs de script. Type : tableau.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

ScriptActivityLogDestination

Destination des journaux. Type : chaîne.

Nom	Type	Description
ActivityOutput	string
ExternalStore	string

ScriptActivityParameter

Paramètres d’un bloc de script.

Nom	Type	Description
direction	ScriptActivityParameterDirection	Direction du paramètre.
name	object	Nom du paramètre. Type : chaîne (ou expression avec chaîne resultType).
size	integer	Taille du paramètre de direction de sortie.
type	ScriptActivityParameterType	Type du paramètre.
value	object	Valeur du paramètre. Type : chaîne (ou expression avec chaîne resultType).

ScriptActivityParameterDirection

Direction du paramètre.

Nom	Type	Description
Input	string
InputOutput	string
Output	string

ScriptActivityParameterType

Type du paramètre.

Nom	Type	Description
Boolean	string
DateTime	string
DateTimeOffset	string
Decimal	string
Double	string
Guid	string
Int16	string
Int32	string
Int64	string
Single	string
String	string
Timespan	string

ScriptActivityScriptBlock

Bloc de scripts de script.

Nom	Type	Description
parameters	ScriptActivityParameter[]	Tableau de paramètres de script. Type : tableau.
text	object	Texte de la requête. Type : chaîne (ou expression avec chaîne resultType).
type	object	Type de la requête. Reportez-vous au ScriptType pour connaître les options valides. Type : chaîne (ou expression avec chaîne resultType).

ScriptActivityTypeProperties.LogSettings

Paramètres de journal de l’activité de script.

Nom	Type	Description
logDestination	ScriptActivityLogDestination	Destination des journaux. Type : chaîne.
logLocationSettings	LogLocationSettings	Les paramètres d’emplacement du journal doivent être fournis par le client lors de l’activation du journal.

SecureInputOutputPolicy

Stratégie d’exécution pour une activité qui prend en charge les entrées et sorties sécurisées.

Nom	Type	Description
secureInput	boolean	Lorsqu’elle est définie sur true, l’entrée de l’activité est considérée comme sécurisée et ne sera pas enregistrée dans la surveillance.
secureOutput	boolean	Lorsqu’elle est définie sur true, la sortie de l’activité est considérée comme sécurisée et ne sera pas journalisée à la surveillance.

SecureString

Définition de chaîne sécurisée Azure Data Factory. La valeur de chaîne est masquée avec des astérisques '*' pendant les appels d’API Get ou List.

Nom	Type	Description
type	string: SecureString	Type du secret.
value	string	Valeur de chaîne sécurisée.

SetVariableActivity

Définissez la valeur d’une variable.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	SecureInputOutputPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: SetVariable	Type d’activité.
typeProperties.setSystemVariable	boolean	Si la valeur est true, elle définit la valeur de retour de l’exécution du pipeline.
typeProperties.value	object	Valeur à définir. Peut être une valeur statique ou une expression.
typeProperties.variableName	string	Nom de la variable dont la valeur doit être définie.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

SkipErrorFile

Ignorez le fichier d’erreur.

Nom	Type	Description
dataInconsistency	object	Ignorez si le fichier source/récepteur a été modifié par d’autres écritures simultanées. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
fileMissing	object	Ignorez si le fichier est supprimé par d’autres clients pendant la copie. La valeur par défaut est true. Type : booléen (ou expression avec resultType booléen).

SparkConfigurationParametrizationReference

Informations de référence sur la configuration Spark.

Nom	Type	Description
referenceName	object	Référencez le nom de configuration spark. Type : chaîne (ou expression avec chaîne resultType).
type	SparkConfigurationReferenceType	Type de référence de configuration Spark.

SparkConfigurationReferenceType

Type de référence de configuration Spark.

Nom	Type	Description
SparkConfigurationReference	string

SparkJobReferenceType

Type de référence de travail Synapse spark.

Nom	Type	Description
SparkJobDefinitionReference	string

SqlServerStoredProcedureActivity

Type d’activité de procédure stockée SQL.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: SqlServerStoredProcedure	Type d’activité.
typeProperties.storedProcedureName	object	Nom de la procédure stockée. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.storedProcedureParameters	object	Paramètre de valeur et de type pour les paramètres de procédure stockée. Exemple : « {Parameter1 : {value : « 1 », tapez : « int"}} ».
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

SSISAccessCredential

Informations d’identification d’accès SSIS.

Nom	Type	Description
domain	object	Domaine pour l’authentification Windows. Type : chaîne (ou expression avec chaîne resultType).
password	SecretBase: AzureKeyVaultSecretReference SecureString	Mot de passe pour l’authentification Windows.
userName	object	UseName pour l’authentification Windows. Type : chaîne (ou expression avec chaîne resultType).

SSISChildPackage

Package enfant incorporé SSIS.

Nom	Type	Description
packageContent	object	Contenu du package enfant incorporé. Type : chaîne (ou expression avec chaîne resultType).
packageLastModifiedDate	string	Date de dernière modification du package enfant incorporé.
packageName	string	Nom du package enfant incorporé.
packagePath	object	Chemin d’accès pour le package enfant incorporé. Type : chaîne (ou expression avec chaîne resultType).

SSISExecutionCredential

Informations d’identification d’exécution du package SSIS.

Nom	Type	Description
domain	object	Domaine pour l’authentification Windows. Type : chaîne (ou expression avec chaîne resultType).
password	SecureString	Mot de passe pour l’authentification Windows.
userName	object	UseName pour l’authentification Windows. Type : chaîne (ou expression avec chaîne resultType).

SSISExecutionParameter

Paramètre d’exécution SSIS.

Nom	Type	Description
value	object	Valeur du paramètre d’exécution du package SSIS. Type : chaîne (ou expression avec chaîne resultType).

SSISLogLocation

Emplacement du journal d’exécution du package SSIS

Nom	Type	Description
logPath	object	Chemin du journal d’exécution du package SSIS. Type : chaîne (ou expression avec chaîne resultType).
type	SsisLogLocationType	Type d’emplacement du journal SSIS.
typeProperties.accessCredential	SSISAccessCredential	Informations d’identification d’accès au journal d’exécution du package.
typeProperties.logRefreshInterval	object	Spécifie l’intervalle d’actualisation du journal. L’intervalle par défaut est de 5 minutes. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).

SsisLogLocationType

Type d’emplacement du journal SSIS.

Nom	Type	Description
File	string

SSISPackageLocation

Emplacement du package SSIS.

Nom	Type	Description
packagePath	object	Chemin du package SSIS. Type : chaîne (ou expression avec chaîne resultType).
type	SsisPackageLocationType	Type d’emplacement du package SSIS.
typeProperties.accessCredential	SSISAccessCredential	Informations d’identification d’accès au package.
typeProperties.childPackages	SSISChildPackage[]	Liste des packages enfants incorporés.
typeProperties.configurationAccessCredential	SSISAccessCredential	Informations d’identification d’accès au fichier de configuration.
typeProperties.configurationPath	object	Fichier de configuration de l’exécution du package. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.packageContent	object	Contenu du package incorporé. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.packageLastModifiedDate	string	Date de dernière modification du package incorporé.
typeProperties.packageName	string	Nom du package.
typeProperties.packagePassword	SecretBase: AzureKeyVaultSecretReference SecureString	Mot de passe du package.

SsisPackageLocationType

Type d’emplacement du package SSIS.

Nom	Type	Description
File	string
InlinePackage	string
PackageStore	string
SSISDB	string

SSISPropertyOverride

Remplacement de propriété SSIS.

Nom	Type	Description
isSensitive	boolean	Indique si la valeur de remplacement de propriété de package SSIS est des données sensibles. La valeur est chiffrée dans SSISDB s’il est vrai
value	object	Valeur de remplacement de la propriété de package SSIS. Type : chaîne (ou expression avec chaîne resultType).

StagingSettings

Paramètres intermédiaires.

Nom	Type	Description
enableCompression	object	Spécifie s’il faut utiliser la compression lors de la copie de données via une préproduction intermédiaire. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié intermédiaire.
path	object	Chemin d’accès au stockage pour stocker les données intermédiaires. Type : chaîne (ou expression avec chaîne resultType).

SwitchActivity

Cette activité évalue une expression et exécute des activités sous la propriété cas qui correspondent à l’évaluation d’expression attendue dans la propriété égale.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Switch	Type d’activité.
typeProperties.cases	SwitchCase[]	Liste des cas qui correspondent aux valeurs attendues de la propriété « on ». Il s’agit d’une propriété facultative et, si elle n’est pas fournie, l’activité exécute les activités fournies dans defaultActivities.
typeProperties.defaultActivities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter si aucune condition de cas n’est satisfaite. Il s’agit d’une propriété facultative et, si elle n’est pas fournie, l’activité s’arrête sans aucune action.
typeProperties.on	Expression	Expression qui évaluerait une chaîne ou un entier. Cela permet de déterminer le bloc d’activités dans les cas qui seront exécutés.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

SwitchCase

Les cas de commutateur avec une valeur et des activités correspondantes.

Nom	Type	Description
activities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter pour une condition de cas satisfaite.
value	string	Valeur attendue qui satisfait le résultat de l’expression de la propriété « on ».

SynapseNotebookActivity

Exécutez l’activité du notebook Synapse.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: SynapseNotebook	Type d’activité.
typeProperties.conf	object	Propriétés de configuration Spark, qui remplacent la « conf » du bloc-notes que vous fournissez.
typeProperties.configurationType	ConfigurationType	Type de la configuration spark.
typeProperties.driverSize	object	Nombre de cœurs et de mémoire à utiliser pour le pilote alloué dans le pool Spark spécifié pour la session, qui sera utilisé pour remplacer « driverCores » et « driverMemory » du notebook que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.executorSize	object	Nombre de cœurs et de mémoire à utiliser pour les exécuteurs alloués dans le pool Spark spécifié pour la session, qui sera utilisé pour remplacer « executorCores » et « executorMemory » du notebook que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.notebook	SynapseNotebookReference	Informations de référence sur le notebook Synapse.
typeProperties.numExecutors	object	Nombre d’exécuteurs à lancer pour cette session, ce qui remplace le « numExecutors » du bloc-notes que vous fournissez. Type : entier (ou Expression avec entier resultType).
typeProperties.parameters	<string,  NotebookParameter>	Paramètres du bloc-notes.
typeProperties.sparkConfig	object	Propriété de configuration Spark.
typeProperties.sparkPool	BigDataPoolParametrizationReference	Nom du pool Big Data qui sera utilisé pour exécuter le notebook.
typeProperties.targetSparkConfiguration	SparkConfigurationParametrizationReference	Configuration spark du travail Spark.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

SynapseNotebookReference

Type de référence de notebook Synapse.

Nom	Type	Description
referenceName	object	Nom du bloc-notes de référence. Type : chaîne (ou expression avec chaîne resultType).
type	NotebookReferenceType	Type de référence de notebook Synapse.

SynapseSparkJobDefinitionActivity

Exécutez l’activité de travail Spark.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: SparkJob	Type d’activité.
typeProperties.args	SynapseSparkJobActivityTypeProperties.Args[]	Arguments spécifiés par l’utilisateur pour SynapseSparkJobDefinitionActivity.
typeProperties.className	object	Identificateur complet ou classe principale qui se trouve dans le fichier de définition principal, qui remplacera « className » de la définition de travail spark que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.conf	object	Propriétés de configuration Spark, qui remplacent le « conf » de la définition de travail Spark que vous fournissez.
typeProperties.configurationType	ConfigurationType	Type de la configuration spark.
typeProperties.driverSize	object	Nombre de cœurs et de mémoire à utiliser pour le pilote alloué dans le pool Spark spécifié pour le travail, qui sera utilisé pour remplacer « driverCores » et « driverMemory » de la définition de travail Spark que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.executorSize	object	Nombre de cœurs et de mémoire à utiliser pour les exécuteurs alloués dans le pool Spark spécifié pour le travail, qui sera utilisé pour remplacer « executorCores » et « executorMemory » de la définition de travail Spark que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.file	object	Fichier principal utilisé pour le travail, qui remplacera le « fichier » de la définition de travail Spark que vous fournissez. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.files	object[]	(Déconseillé. Utilisez pythonCodeReference et filesV2) Fichiers supplémentaires utilisés pour référence dans le fichier de définition principal, qui remplacent les « fichiers » de la définition de travail Spark que vous fournissez.
typeProperties.filesV2	object[]	Fichiers supplémentaires utilisés pour référence dans le fichier de définition principal, qui remplacent les « fichiers jar » et « fichiers » de la définition de travail Spark que vous fournissez.
typeProperties.numExecutors	object	Nombre d’exécuteurs à lancer pour ce travail, qui remplacent « numExecutors » de la définition de travail Spark que vous fournissez. Type : entier (ou Expression avec entier resultType).
typeProperties.pythonCodeReference	object[]	Fichiers de code Python supplémentaires utilisés pour référence dans le fichier de définition principal, qui remplacent les « pyFiles » de la définition de travail Spark que vous fournissez.
typeProperties.scanFolder	object	Analyse des sous-dossiers à partir du dossier racine du fichier de définition principal, ces fichiers seront ajoutés en tant que fichiers de référence. Les dossiers nommés « jars », « pyFiles », « fichiers » ou « archives » sont analysés et le nom des dossiers respecte la casse. Type : booléen (ou expression avec resultType booléen).
typeProperties.sparkConfig	object	Propriété de configuration Spark.
typeProperties.sparkJob	SynapseSparkJobReference	Informations de référence sur les travaux Synapse spark.
typeProperties.targetBigDataPool	BigDataPoolParametrizationReference	Nom du pool Big Data qui sera utilisé pour exécuter le travail de traitement par lots Spark, qui remplacera le « targetBigDataPool » de la définition de travail spark que vous fournissez.
typeProperties.targetSparkConfiguration	SparkConfigurationParametrizationReference	Configuration spark du travail Spark.
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

SynapseSparkJobReference

Type de référence de travail Synapse spark.

Nom	Type	Description
referenceName	object	Référencez le nom du travail Spark. Expression avec chaîne resultType.
type	SparkJobReferenceType	Type de référence de travail Synapse spark.

Type

Type de référence de service lié.

Nom	Type	Description
LinkedServiceReference	string

UntilActivity

Cette activité exécute des activités internes jusqu’à ce que les résultats de l’expression booléenne spécifiés soient true ou que le délai d’expiration soit atteint, selon ce qui est antérieur.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Until	Type d’activité.
typeProperties.activities	Activity[]: AppendVariableActivity[] AzureDataExplorerCommandActivity[] AzureFunctionActivity[] AzureMLBatchExecutionActivity[] AzureMLExecutePipelineActivity[] AzureMLUpdateResourceActivity[] ControlActivity[] CopyActivity[] CustomActivity[] DataLakeAnalyticsUSQLActivity[] DatabricksNotebookActivity[] DatabricksSparkJarActivity[] DatabricksSparkPythonActivity[] DeleteActivity[] ExecuteDataFlowActivity[] ExecutePipelineActivity[] ExecuteSSISPackageActivity[] ExecuteWranglingDataflowActivity[] ExecutionActivity[] FailActivity[] FilterActivity[] ForEachActivity[] GetMetadataActivity[] HDInsightHiveActivity[] HDInsightMapReduceActivity[] HDInsightPigActivity[] HDInsightSparkActivity[] HDInsightStreamingActivity[] IfConditionActivity[] LookupActivity[] ScriptActivity[] SetVariableActivity[] SqlServerStoredProcedureActivity[] SwitchActivity[] SynapseNotebookActivity[] SynapseSparkJobDefinitionActivity[] UntilActivity[] ValidationActivity[] WaitActivity[] WebActivity[] WebHookActivity[]	Liste des activités à exécuter.
typeProperties.expression	Expression	Expression qui évaluerait booléen. La boucle continue jusqu’à ce que cette expression soit évaluée à true
typeProperties.timeout	object	Spécifie le délai d’expiration de l’activité à exécuter. S’il n’existe aucune valeur spécifiée, il prend la valeur de TimeSpan.FromDays(7) qui est de 1 semaine par défaut. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

UserProperty

Propriété utilisateur.

Nom	Type	Description
name	string	Nom de propriété utilisateur.
value	object	Valeur de propriété utilisateur. Type : chaîne (ou expression avec chaîne resultType).

ValidationActivity

Cette activité vérifie qu’une ressource externe existe.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Validation	Type d’activité.
typeProperties.childItems	object	Peut être utilisé si le jeu de données pointe vers un dossier. Si la valeur est true, le dossier doit avoir au moins un fichier. Si la valeur est false, le dossier doit être vide. Type : booléen (ou expression avec resultType booléen).
typeProperties.dataset	DatasetReference	Référence du jeu de données d’activité de validation.
typeProperties.minimumSize	object	Peut être utilisé si le jeu de données pointe vers un fichier. Le fichier doit être supérieur ou égal à la valeur spécifiée. Type : entier (ou Expression avec entier resultType).
typeProperties.sleep	object	Délai en secondes entre les tentatives de validation. Si aucune valeur n’est spécifiée, 10 secondes seront utilisées comme valeur par défaut. Type : entier (ou Expression avec entier resultType).
typeProperties.timeout	object	Spécifie le délai d’expiration de l’activité à exécuter. S’il n’existe aucune valeur spécifiée, il prend la valeur de TimeSpan.FromDays(7) qui est de 1 semaine par défaut. Type : chaîne (ou expression avec chaîne resultType), modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

VariableSpecification

Définition d’une variable unique pour un pipeline.

Nom	Type	Description
defaultValue	object	Valeur par défaut de la variable.
type	VariableType	Type de variable.

VariableType

Type de variable.

Nom	Type	Description
Array	string
Bool	string
String	string

WaitActivity

Cette activité interrompt l’exécution du pipeline pour l’intervalle spécifié.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: Wait	Type d’activité.
typeProperties.waitTimeInSeconds	object	Durée en secondes. Type : entier (ou Expression avec entier resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

WebActivity

Activité web.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
linkedServiceName	LinkedServiceReference	Informations de référence sur le service lié.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	ActivityPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: WebActivity	Type d’activité.
typeProperties.authentication	WebActivityAuthentication	Méthode d’authentification utilisée pour appeler le point de terminaison.
typeProperties.body	object	Représente la charge utile qui sera envoyée au point de terminaison. Obligatoire pour la méthode POST/PUT, non autorisée pour le type de méthode GET : chaîne (ou expression avec chaîne resultType).
typeProperties.connectVia	IntegrationRuntimeReference	Référence du runtime d’intégration.
typeProperties.datasets	DatasetReference[]	Liste des jeux de données passés au point de terminaison web.
typeProperties.disableCertValidation	boolean	Lorsque la valeur est true, la validation du certificat est désactivée.
typeProperties.headers	object	Représente les en-têtes qui seront envoyés à la demande. Par exemple, pour définir la langue et le type sur une demande : « headers » : { « Accept-Language » : «en-us», « Content-Type » : « application/json » }. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.httpRequestTimeout	object	Délai d’expiration de la requête HTTP pour obtenir une réponse. Le format est dans TimeSpan (hh :mm :ss). Cette valeur est le délai d’expiration pour obtenir une réponse, et non le délai d’expiration de l’activité. La valeur par défaut est 00:01:00 (1 minute). La plage est comprise entre 1 et 10 minutes
typeProperties.linkedServices	LinkedServiceReference[]	Liste des services liés passés au point de terminaison web.
typeProperties.method	WebActivityMethod	Méthode API Rest pour le point de terminaison cible.
typeProperties.turnOffAsync	boolean	Option permettant de désactiver l’appel de HTTP GET à l’emplacement donné dans l’en-tête de réponse d’une réponse HTTP 202. Si la valeur est true, elle cesse d’appeler HTTP GET sur l’emplacement http donné dans l’en-tête de réponse. Si la valeur est false, continue d’appeler l’appel HTTP GET à l’emplacement donné dans les en-têtes de réponse HTTP.
typeProperties.url	object	Point de terminaison et chemin cible de l’activité web. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

WebActivityAuthentication

Propriétés d’authentification d’activité web.

Nom	Type	Description
credential	CredentialReference	Référence des informations d’identification contenant des informations d’authentification.
password	SecretBase: AzureKeyVaultSecretReference SecureString	Mot de passe pour le fichier PFX ou l’authentification de base / Secret lorsqu’il est utilisé pour ServicePrincipal
pfx	SecretBase: AzureKeyVaultSecretReference SecureString	Contenu codé en base64 d’un fichier PFX ou d’un certificat lorsqu’il est utilisé pour ServicePrincipal
resource	object	Ressource pour laquelle le jeton Azure Auth sera demandé lors de l’utilisation de l’authentification MSI. Type : chaîne (ou expression avec chaîne resultType).
type	string	Authentification de l’activité web (Basic/ClientCertificate/MSI/ServicePrincipal)
userTenant	object	TenantId pour lequel le jeton Azure Auth sera demandé lors de l’utilisation de l’authentification ServicePrincipal. Type : chaîne (ou expression avec chaîne resultType).
username	object	Nom d’utilisateur d’authentification d’activité web pour l’authentification de base ou ClientID lorsqu’il est utilisé pour ServicePrincipal. Type : chaîne (ou expression avec chaîne resultType).

WebActivityMethod

Liste des méthodes HTTP prises en charge par un WebActivity.

Nom	Type	Description
DELETE	string
GET	string
POST	string
PUT	string

WebHookActivity

Activité webHook.

Nom	Type	Description
dependsOn	ActivityDependency[]	L’activité dépend de la condition.
description	string	Description de l’activité.
name	string	Nom de l’activité.
onInactiveMarkAs	ActivityOnInactiveMarkAs	Résultat de l’état de l’activité lorsque l’état est défini sur Inactif. Il s’agit d’une propriété facultative et, si elle n’est pas fournie lorsque l’activité est inactive, l’état est réussi par défaut.
policy	SecureInputOutputPolicy	Stratégie d’activité.
state	ActivityState	État de l’activité. Il s’agit d’une propriété facultative et, s’il n’est pas fourni, l’état est actif par défaut.
type	string: WebHook	Type d’activité.
typeProperties.authentication	WebActivityAuthentication	Méthode d’authentification utilisée pour appeler le point de terminaison.
typeProperties.body	object	Représente la charge utile qui sera envoyée au point de terminaison. Obligatoire pour la méthode POST/PUT, non autorisée pour le type de méthode GET : chaîne (ou expression avec chaîne resultType).
typeProperties.headers	object	Représente les en-têtes qui seront envoyés à la demande. Par exemple, pour définir la langue et le type sur une demande : « headers » : { « Accept-Language » : «en-us», « Content-Type » : « application/json » }. Type : chaîne (ou expression avec chaîne resultType).
typeProperties.method	WebHookActivityMethod	Méthode API Rest pour le point de terminaison cible.
typeProperties.reportStatusOnCallBack	object	Lorsque la valeur est true, statusCode, output et error dans le corps de la demande de rappel sont consommées par activité. L’activité peut être marquée comme ayant échoué en définissant statusCode >= 400 dans la demande de rappel. La valeur par défaut est false. Type : booléen (ou expression avec resultType booléen).
typeProperties.timeout	string	Délai d’expiration dans lequel le webhook doit être rappelé. S’il n’existe aucune valeur spécifiée, la valeur par défaut est de 10 minutes. Type : chaîne. Modèle : ((\d+).) ? (\d\d):(60|( [0-5][0-9])):(60|( [0-5][0-9])).
typeProperties.url	object	Point de terminaison et chemin cible de l’activité WebHook. Type : chaîne (ou expression avec chaîne resultType).
userProperties	UserProperty[]	Propriétés de l’utilisateur d’activité.

WebHookActivityMethod

Liste des méthodes HTTP prises en charge par une activité WebHook.

Nom	Type	Description
POST	string