az datafactory pipeline

Uwaga

Ta dokumentacja jest częścią rozszerzenia datafactory dla interfejsu wiersza polecenia platformy Azure (wersja 2.15.0 lub nowsza). Rozszerzenie zostanie automatycznie zainstalowane przy pierwszym uruchomieniu polecenia az datafactory pipeline . Dowiedz się więcej o rozszerzeniach.

Zarządzanie potokiem przy użyciu funkcji datafactory.

Polecenia

az datafactory pipeline create

Tworzenie potoku.

az datafactory pipeline create-run

Tworzy uruchomienie potoku.

az datafactory pipeline delete

Usuwa potok.

az datafactory pipeline list

Wyświetla listę potoków.

az datafactory pipeline show

Pobiera potok.

az datafactory pipeline update

Aktualizowanie potoku.

az datafactory pipeline create

Tworzenie potoku.

az datafactory pipeline create --factory-name
                               --name
                               --pipeline
                               --resource-group
                               [--if-match]

Przykłady

Pipelines_Create

az datafactory pipeline create --factory-name "exampleFactoryName" --pipeline "{\"activities\":[{\"name\":\"ExampleForeachActivity\",\"type\":\"ForEach\",\"typeProperties\":{\"activities\":[{\"name\":\"ExampleCopyActivity\",\"type\":\"Copy\",\"inputs\":[{\"type\":\"DatasetReference\",\"parameters\":{\"MyFileName\":\"examplecontainer.csv\",\"MyFolderPath\":\"examplecontainer\"},\"referenceName\":\"exampleDataset\"}],\"outputs\":[{\"type\":\"DatasetReference\",\"parameters\":{\"MyFileName\":{\"type\":\"Expression\",\"value\":\"@item()\"},\"MyFolderPath\":\"examplecontainer\"},\"referenceName\":\"exampleDataset\"}],\"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\"}},\"variables\":{\"TestVariableArray\":{\"type\":\"Array\"}},\"runDimensions\":{\"JobId\":{\"type\":\"Expression\",\"value\":\"@pipeline().parameters.JobId\"}},\"duration\":\"0.00:10:00\"}" --name "examplePipeline" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--name --pipeline-name -n

Nazwa potoku.

--pipeline

Definicja zasobu potoku. Oczekiwana wartość: json-string/json-file/@json-file.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--if-match

Element ETag jednostki potoku. Należy określić tylko aktualizację, dla której powinna być zgodna z istniejącą jednostką lub może być * dla aktualizacji bezwarunkowej.

az datafactory pipeline create-run

Tworzy uruchomienie potoku.

az datafactory pipeline create-run --factory-name
                                   --name
                                   --resource-group
                                   [--is-recovery {false, true}]
                                   [--parameters]
                                   [--reference-pipeline-run-id]
                                   [--start-activity-name]
                                   [--start-from-failure {false, true}]

Przykłady

Pipelines_CreateRun

az datafactory pipeline create-run --factory-name "exampleFactoryName" --parameters "{\"OutputBlobNameList\":[\"exampleoutput.csv\"]}" --name "examplePipeline" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--name --pipeline-name -n

Nazwa potoku.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--is-recovery

Flaga trybu odzyskiwania. Jeśli tryb odzyskiwania ma wartość true, określony przywoływane uruchomienie potoku, a nowe uruchomienie zostanie zgrupowane w ramach tego samego identyfikatora groupId.

akceptowane wartości: false, true
--parameters

Parametry przebiegu potoku. Te parametry będą używane tylko wtedy, gdy nie określono identyfikatora runId. Oczekiwana wartość: json-string/json-file/@json-file.

--reference-pipeline-run-id

Identyfikator uruchomienia potoku. Jeśli określono identyfikator przebiegu, parametry określonego przebiegu zostaną użyte do utworzenia nowego przebiegu.

--start-activity-name

W trybie odzyskiwania ponowne uruchomienie rozpocznie się od tego działania. Jeśli nie zostanie określony, zostaną uruchomione wszystkie działania.

--start-from-failure

W trybie odzyskiwania, jeśli ustawiono wartość true, ponowne uruchomienie rozpocznie się od działań, które zakończyły się niepowodzeniem. Właściwość będzie używana tylko wtedy, gdy parametr startActivityName nie zostanie określony.

akceptowane wartości: false, true

az datafactory pipeline delete

Usuwa potok.

az datafactory pipeline delete --factory-name
                               --name
                               --resource-group
                               [--yes]

Przykłady

Pipelines_Delete

az datafactory pipeline delete --factory-name "exampleFactoryName" --name "examplePipeline" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--name --pipeline-name -n

Nazwa potoku.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--yes -y

Nie monituj o potwierdzenie.

az datafactory pipeline list

Wyświetla listę potoków.

az datafactory pipeline list --factory-name
                             --resource-group

Przykłady

Pipelines_ListByFactory

az datafactory pipeline list --factory-name "exampleFactoryName" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

az datafactory pipeline show

Pobiera potok.

az datafactory pipeline show --factory-name
                             --name
                             --resource-group
                             [--if-none-match]

Przykłady

Pipelines_Get

az datafactory pipeline show --factory-name "exampleFactoryName" --name "examplePipeline" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--name --pipeline-name -n

Nazwa potoku.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--if-none-match

Element ETag jednostki potoku. Należy określić tylko dla polecenia get. Jeśli element ETag pasuje do istniejącego tagu jednostki lub jeśli * został podany, nie zostanie zwrócona żadna zawartość.

az datafactory pipeline update

Aktualizowanie potoku.

az datafactory pipeline update --factory-name
                               --name
                               --resource-group
                               [--activities]
                               [--add]
                               [--annotations]
                               [--concurrency]
                               [--description]
                               [--duration]
                               [--folder-name]
                               [--force-string]
                               [--if-match]
                               [--if-none-match]
                               [--parameters]
                               [--remove]
                               [--run-dimensions]
                               [--set]
                               [--variables]

Przykłady

Pipelines_Update

az datafactory pipeline update --factory-name "exampleFactoryName" --description "Example description" --activities "[{\"name\":\"ExampleForeachActivity\",\"type\":\"ForEach\",\"typeProperties\":{\"activities\":[{\"name\":\"ExampleCopyActivity\",\"type\":\"Copy\",\"inputs\":[{\"type\":\"DatasetReference\",\"parameters\":{\"MyFileName\":\"examplecontainer.csv\",\"MyFolderPath\":\"examplecontainer\"},\"referenceName\":\"exampleDataset\"}],\"outputs\":[{\"type\":\"DatasetReference\",\"parameters\":{\"MyFileName\":{\"type\":\"Expression\",\"value\":\"@item()\"},\"MyFolderPath\":\"examplecontainer\"},\"referenceName\":\"exampleDataset\"}],\"typeProperties\":{\"dataIntegrationUnits\":32,\"sink\":{\"type\":\"BlobSink\"},\"source\":{\"type\":\"BlobSource\"}}}],\"isSequential\":true,\"items\":{\"type\":\"Expression\",\"value\":\"@pipeline().parameters.OutputBlobNameList\"}}}]" --parameters "{\"OutputBlobNameList\":{\"type\":\"Array\"}}" --duration "0.00:10:00" --name "examplePipeline" --resource-group "exampleResourceGroup"

Parametry wymagane

--factory-name

Nazwa fabryki.

--name --pipeline-name -n

Nazwa potoku.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--activities

Lista działań w potoku. Oczekiwana wartość: json-string/json-file/@json-file.

--add

Dodaj obiekt do listy obiektów, określając pary ścieżki i wartości klucza. Przykład: --add property.listProperty <key=value, string lub ciąg JSON>.

--annotations

Lista tagów, których można użyć do opisywania potoku. Oczekiwana wartość: json-string/json-file/@json-file.

--concurrency

Maksymalna liczba współbieżnych przebiegów dla potoku.

--description

Opis potoku.

--duration

Wartość TimeSpan, po której zostanie wyzwolona metryka monitorowania platformy Azure. Oczekiwana wartość: json-string/json-file/@json-file.

--folder-name

Nazwa folderu, w ramach którego znajduje się ten potok.

--force-string

W przypadku używania polecenia "set" lub "add" zachowaj literały ciągu zamiast próbować konwertować na format JSON.

--if-match

Element ETag jednostki potoku. Należy określić tylko aktualizację, dla której powinna być zgodna z istniejącą jednostką lub może być * dla aktualizacji bezwarunkowej.

--if-none-match

Element ETag jednostki potoku. Należy określić tylko dla polecenia get. Jeśli element ETag pasuje do istniejącego tagu jednostki lub jeśli * został podany, nie zostanie zwrócona żadna zawartość.

--parameters

Lista parametrów potoku. Oczekiwana wartość: json-string/json-file/@json-file.

--remove

Usuń właściwość lub element z listy. Przykład: --remove property.list OR --remove propertyToRemove.

--run-dimensions

Wymiary emitowane przez potok. Oczekiwana wartość: json-string/json-file/@json-file.

--set

Zaktualizuj obiekt, określając ścieżkę właściwości i wartość do ustawienia. Przykład: --set property1.property2=.

--variables

Lista zmiennych dla potoku. Oczekiwana wartość: json-string/json-file/@json-file.