在 Azure Data Factory 和 Synapse Analytics 管線中的 If 條件活動

發行項
06/03/2024

適用於：Azure Data Factory Azure Synapse Analytics

提示

試用 Microsoft Fabric 中的 Data Factory，這是適用於企業的全方位分析解決方案。 Microsoft Fabric 涵蓋從資料移動到資料科學、即時分析、商業智慧和報告的所有項目。了解如何免費啟動新的試用版！

If 條件活動所提供的功能，與 If 陳述式在程式設計語言中提供的功能相同。它能在條件評估為 true 時執行一系列活動，並在條件評估為 false 時執行另一系列活動。

使用 UI 建立 If 條件活動

若要在管線中使用 If 條件活動，請完成下列步驟：

在管線 [活動] 窗格中搜尋 If，然後將 If 條件活動拖曳至管線畫布。
在畫布上選取新的 If 條件活動 (若未選取)，再選取其 [活動] 索引標籤以編輯詳細資料。
輸入傳回布林值 true 或 false 值的運算式。這可以是運算式、函式、系統變數或其他活動輸出項目的任意動態組合。
選取 If 條件 [活動] 索引標籤上的 [編輯活動] 按鈕，或直接從管線畫布上的 If 條件，新增運算式評估為 true 或 false 時會執行的活動。

語法


{
    "name": "<Name of the activity>",
    "type": "IfCondition",
    "typeProperties": {
		    "expression": {
            "value": "<expression that evaluates to true or false>",
            "type": "Expression"
		    },

		    "ifTrueActivities": [
            {
                "<Activity 1 definition>"
            },
            {
                "<Activity 2 definition>"
            },
            {
                "<Activity N definition>"
            }
        ],

        "ifFalseActivities": [
            {
                "<Activity 1 definition>"
            },
            {
                "<Activity 2 definition>"
            },
            {
                "<Activity N definition>"
            }
		    ]
    }
}

類型屬性

屬性	說明	允許的值	必要
NAME	If-Condition 活動的名稱。	String	Yes
type	必須設為 [IfCondition]	String	Yes
expression	必須評估為 true 或 false 的運算式	結果類型為布林的運算式	Yes
ifTrueActivities	會在運算式評估為 `true` 時執行的一系列活動。	陣列	Yes
ifFalseActivities	會在運算式評估為 `false` 時執行的一系列活動。	陣列	Yes

範例

此範例中的管線會將資料從輸入資料夾複製到輸出資料夾。輸出資料夾是由下列管線參數的值所決定：routeSelection。如果 routeSelection 的值為 true，資料將會被複製到 outputPath1。而如果 routeSelection 的值為 false，資料將會被複製到 outputPath2。

注意

本節提供 JSON 定義和 PowerShell 命令範例，以供執行管線。針對使用 Azure PowerShell 和 JSON 定義來建立管線，如需包含逐步指示的逐步解說，請參閱教學課程：使用 Azure PowerShell 來建立資料處理站。

具有 IF-Condition 活動的管線 (Adfv2QuickStartPipeline.json)

{
    "name": "Adfv2QuickStartPipeline",
    "properties": {
        "activities": [
            {
                "name": "MyIfCondition",
                "type": "IfCondition",
                "typeProperties": {
                    "expression":  {
                        "value":  "@bool(pipeline().parameters.routeSelection)", 
                        "type": "Expression"
                     },
                                           
                    "ifTrueActivities": [
                        {
                            "name": "CopyFromBlobToBlob1",
                            "type": "Copy",
                            "inputs": [
                                {
                                    "referenceName": "BlobDataset",
                                    "parameters": {
                                        "path": "@pipeline().parameters.inputPath"
                                    },
                                    "type": "DatasetReference"
                                }
                            ],
                            "outputs": [
                                {
                                    "referenceName": "BlobDataset",
                                    "parameters": {
                                        "path": "@pipeline().parameters.outputPath1"
                                    },
                                    "type": "DatasetReference"
                                }
                            ],
                            "typeProperties": {
                                "source": {
                                    "type": "BlobSource"
                                },
                                "sink": {
                                    "type": "BlobSink"
                                }
                            }
                        }                                   
                    ],
                    "ifFalseActivities": [
                        {
                            "name": "CopyFromBlobToBlob2",
                            "type": "Copy",
                            "inputs": [
                                {
                                    "referenceName": "BlobDataset",
                                    "parameters": {
                                        "path": "@pipeline().parameters.inputPath"
                                    },
                                    "type": "DatasetReference"
                                }
                            ],
                            "outputs": [
                                {
                                    "referenceName": "BlobDataset",
                                    "parameters": {
                                        "path": "@pipeline().parameters.outputPath2"
                                    },
                                    "type": "DatasetReference"
                                }
                            ],
                            "typeProperties": {
                                "source": {
                                    "type": "BlobSource"
                                },
                                "sink": {
                                    "type": "BlobSink"
                                }
                            }
                        }
                    ]                    
                }
            }
        ],
        "parameters": {
            "inputPath": {
                "type": "String"
            },
            "outputPath1": {
                "type": "String"
            },
            "outputPath2": {
                "type": "String"
            },
            "routeSelection": {
                "type": "String"
            }                        
        }
    }
}

另一個運算式的範例為：

"expression":  {
    "value":  "@equals(pipeline().parameters.routeSelection,1)", 
    "type": "Expression"
}

Azure 儲存體連結服務 (AzureStorageLinkedService.json)

{
    "name": "AzureStorageLinkedService",
    "properties": {
        "type": "AzureStorage",
        "typeProperties": {
            "connectionString": "DefaultEndpointsProtocol=https;AccountName=<Azure Storage account name>;AccountKey=<Azure Storage account key>"
        }
    }
}

參數化 Azure Blob 資料集 (BlobDataset.json)

管線會將 folderPath 設定為管線的 outputPath1 或 outputPath2 參數。

{
    "name": "BlobDataset",
    "properties": {
        "type": "AzureBlob",
        "typeProperties": {
            "folderPath": {
                "value": "@{dataset().path}",
                "type": "Expression"
            }
        },
        "linkedServiceName": {
            "referenceName": "AzureStorageLinkedService",
            "type": "LinkedServiceReference"
        },
        "parameters": {
            "path": {
                "type": "String"
            }
        }
    }
}

管線參數 JSON (PipelineParameters.json)

{
    "inputPath": "adftutorial/input",
    "outputPath1": "adftutorial/outputIf",
    "outputPath2": "adftutorial/outputElse",
    "routeSelection": "false"
}

PowerShell 命令

注意

建議您使用 Azure Az PowerShell 模組來與 Azure 互動。若要開始使用，請參閱安裝 Azure PowerShell。若要了解如何移轉至 Az PowerShell 模組，請參閱將 Azure PowerShell 從 AzureRM 移轉至 Az。

這些命令假設您已將 JSON 檔案儲存至下列資料夾：C:\ADF。

Connect-AzAccount
Select-AzSubscription "<Your subscription name>"

$resourceGroupName = "<Resource Group Name>"
$dataFactoryName = "<Data Factory Name. Must be globally unique>";
Remove-AzDataFactoryV2 $dataFactoryName -ResourceGroupName $resourceGroupName -force


Set-AzDataFactoryV2 -ResourceGroupName $resourceGroupName -Location "East US" -Name $dataFactoryName
Set-AzDataFactoryV2LinkedService -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "AzureStorageLinkedService" -DefinitionFile "C:\ADF\AzureStorageLinkedService.json"
Set-AzDataFactoryV2Dataset -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "BlobDataset" -DefinitionFile "C:\ADF\BlobDataset.json"
Set-AzDataFactoryV2Pipeline -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "Adfv2QuickStartPipeline" -DefinitionFile "C:\ADF\Adfv2QuickStartPipeline.json"
$runId = Invoke-AzDataFactoryV2Pipeline -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -PipelineName "Adfv2QuickStartPipeline" -ParameterFile C:\ADF\PipelineParameters.json
while ($True) {
    $run = Get-AzDataFactoryV2PipelineRun -ResourceGroupName $resourceGroupName -DataFactoryName $DataFactoryName -PipelineRunId $runId

    if ($run) {
        if ($run.Status -ne 'InProgress') {
            Write-Host "Pipeline run finished. The status is: " $run.Status -foregroundcolor "Yellow"
            $run
            break
        }
        Write-Host  "Pipeline is running...status: InProgress" -foregroundcolor "Yellow"
    }

    Start-Sleep -Seconds 30
}
Write-Host "Activity run details:" -foregroundcolor "Yellow"
$result = Get-AzDataFactoryV2ActivityRun -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -PipelineRunId $runId -RunStartedAfter (Get-Date).AddMinutes(-30) -RunStartedBefore (Get-Date).AddMinutes(30)
$result

Write-Host "Activity 'Output' section:" -foregroundcolor "Yellow"
$result.Output -join "`r`n"

Write-Host "\nActivity 'Error' section:" -foregroundcolor "Yellow"
$result.Error -join "`r`n"

查看其他支援的控制流程活動：

共用方式為

在 Azure Data Factory 和 Synapse Analytics 管線中的 If 條件活動

使用 UI 建立 If 條件活動

語法

類型屬性

範例

具有 IF-Condition 活動的管線 (Adfv2QuickStartPipeline.json)

Azure 儲存體連結服務 (AzureStorageLinkedService.json)

參數化 Azure Blob 資料集 (BlobDataset.json)

管線參數 JSON (PipelineParameters.json)

PowerShell 命令

意見反應

其他資源

共用方式為

在 Azure Data Factory 和 Synapse Analytics 管線中的 If 條件活動

使用 UI 建立 If 條件活動

語法

類型屬性

範例

具有 IF-Condition 活動的管線 (Adfv2QuickStartPipeline.json)

Azure 儲存體連結服務 (AzureStorageLinkedService.json)

參數化 Azure Blob 資料集 (BlobDataset.json)

管線參數 JSON (PipelineParameters.json)

PowerShell 命令

相關內容

意見反應

其他資源