共用方式為


管線執行中的參考觸發程序中繼資料

適用於:Azure Data Factory Azure Synapse Analytics

提示

試用 Microsoft Fabric 中的 Data Factory,這是適用於企業的全方位分析解決方案。 Microsoft Fabric 涵蓋從資料移動到資料科學、即時分析、商業智慧和報告的所有項目。 了解如何免費開始新的試用 (部分機器翻譯)!

本文說明如何在管線執行中使用觸發程序中繼資料,例如觸發程序開始時間。

管線有時需要了解並從叫用它的觸發程序中讀取中繼資料。 例如,使用輪轉視窗觸發程序執行,根據視窗開始和結束時間,管線會處理不同的資料配量或資料夾。 在 Azure Data Factory 中,我們使用參數化和系統變數,將中繼資料從觸發程序傳遞至管線。

此模式特別適用於輪轉視窗觸發程序 (其中觸發程序會提供視窗開始和結束時間) 以及自訂事件觸發程序 (其中觸發程序剖析和處理值在自訂定義的資料欄位中很重要)。

注意

不同的觸發程序類型提供不同的中繼資料資訊。 如需詳細資訊,請參閱系統變數

Data Factory UI

本節說明如何在 Data Factory 使用者介面 (UI) 內,將中繼資料資訊從觸發程序傳遞至管線。

  1. 前往製作畫布並編輯管線。

  2. 選取空白畫布以顯示管線設定。 請勿選取任何活動。 您可能需要從畫布底部提取設定面板,因為它可能已摺疊。

  3. 選取 [參數] 索引標籤,然後選取 [+ 新增] 以新增參數。

    此螢幕擷取畫面顯示管線設定,其中顯示如何在管線中定義參數。

  4. 選取 [+ 觸發程序],將觸發程序新增至管線。

  5. 建立或附加觸發程序至管線,然後選取 [確定]

  6. 選取 [確定] 之後,會顯示另一個 [新增觸發程序] 頁面,其中包含該管線的指定參數清單,如下列螢幕擷取畫面所示。 在該頁面上,填入每個參數的觸發程序中繼資料。 使用系統變數中定義的格式來擷取觸發程序資訊。 您不需要填入所有參數的資訊。 只要填入要假設觸發程序中繼資料值的資訊即可。 例如,我們會在這裡將觸發程序執行開始時間指派為 parameter_1

    此螢幕擷取畫面顯示 [觸發程序執行參數] 頁面,其中顯示如何將觸發程序資訊傳遞至管線參數。

  7. 若要使用管線中的值,請在管線定義中使用參數,例如 @pipeline().parameters.parameterName,而不是系統變數。 例如在此案例中,若要讀取觸發程序開始時間,我們會參考 @pipeline().parameters.parameter_1

JSON 結構描述

若要將觸發程序資訊傳遞至管線執行,觸發程序和管線 JSON 都必須使用 parameters 區段來更新。

管線定義

properties 區段底下,將參數定義新增至 parameters 區段。

{
    "name": "demo_pipeline",
    "properties": {
        "activities": [
            {
                "name": "demo_activity",
                "type": "WebActivity",
                "dependsOn": [],
                "policy": {
                    "timeout": "7.00:00:00",
                    "retry": 0,
                    "retryIntervalInSeconds": 30,
                    "secureOutput": false,
                    "secureInput": false
                },
                "userProperties": [],
                "typeProperties": {
                    "url": {
                        "value": "@pipeline().parameters.parameter_2",
                        "type": "Expression"
                    },
                    "method": "GET"
                }
            }
        ],
        "parameters": {
            "parameter_1": {
                "type": "string"
            },
            "parameter_2": {
                "type": "string"
            },
            "parameter_3": {
                "type": "string"
            },
            "parameter_4": {
                "type": "string"
            },
            "parameter_5": {
                "type": "string"
            }
        },
        "annotations": [],
        "lastPublishTime": "2021-02-24T03:06:23Z"
    },
    "type": "Microsoft.DataFactory/factories/pipelines"
}

觸發程序定義

pipelines 區段底下的 parameters 區段中指派參數值。 您不需要填入所有參數的資訊。 只要填入要假設觸發程序中繼資料值的資訊即可。

{
    "name": "trigger1",
    "properties": {
        "annotations": [],
        "runtimeState": "Started",
        "pipelines": [
            {
                "pipelineReference": {
                    "referenceName": "demo_pipeline",
                    "type": "PipelineReference"
                },
                "parameters": {
                    "parameter_1": "@trigger().startTime"
                }
            }
        ],
        "type": "ScheduleTrigger",
        "typeProperties": {
            "recurrence": {
                "frequency": "Minute",
                "interval": 15,
                "startTime": "2021-03-03T04:38:00Z",
                "timeZone": "UTC"
            }
        }
    }
}

在管線中使用觸發程序資訊

若要使用管線中的值,請在管線定義中使用參數,例如 @pipeline().parameters.parameterName,而不是系統變數。

如需觸發程序的詳細資訊,請參閱管線執行和觸發程序