建立依輪轉視窗執行管線的觸發程序

適用於： Azure Data Factory Azure Synapse Analytics

本文章提供建立、啟動、監視輪轉視窗觸發程序的步驟。 如需觸發程式和支援類型的一般資訊，請參閱 管線執行和觸發程式。

輪轉視窗觸發程序是可從指定的開始時間定期引發，同時還能保留狀態的一種觸發程序。 輪轉視窗範圍是一系列大小固定、非重疊的連續時間間隔。 輪轉視窗觸發程序與管線會有一對一的關係，並只能參考單一管線。

對於排程觸發程序來說，輪轉視窗觸發程序是更重要的替代方案。 它針對複雜案例提供一套功能，例如（與其他輪轉視窗觸發程式相依性、 重新執行失敗的工作，以及 設定管線的使用者重試）。 若要進一步瞭解排程觸發程式和輪轉視窗觸發程式之間的差異，請參閱 觸發程式類型比較。

Azure Data Factory 和 Azure Synapse 入口網站體驗

1. 若要在 Azure 入口網站中建立輪轉時間範圍觸發程序，請選取 [觸發程序] 索引標籤，然後選取 [新增]。
2. 觸發程序組態窗格開啟之後，選取 [輪轉視窗]。 然後定義輪轉視窗觸發程序屬性。
3. 當您完成時，請選取 [ 儲存]。

輪轉視窗觸發程序類型屬性

輪轉視窗有下列觸發程序類型屬性：

{
    "name": "MyTriggerName",
    "properties": {
        "type": "TumblingWindowTrigger",
        "runtimeState": "<<Started/Stopped/Disabled - readonly>>",
        "typeProperties": {
            "frequency": <<Minute/Hour>>,
            "interval": <<int>>,
            "startTime": "<<datetime>>",
            "endTime": <<datetime - optional>>,
            "delay": <<timespan - optional>>,
            "maxConcurrency": <<int>> (required, max allowed: 50),
            "retryPolicy": {
                "count": <<int - optional, default: 0>>,
                "intervalInSeconds": <<int>>,
            },
            "dependsOn": [
                {
                    "type": "TumblingWindowTriggerDependencyReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan - optional>>,
                    "referenceTrigger": {
                        "referenceName": "MyTumblingWindowDependency1",
                        "type": "TriggerReference"
                    }
                },
                {
                    "type": "SelfDependencyTumblingWindowTriggerReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan>>
                }
            ]
        },
        "pipeline": {
            "pipelineReference": {
                "type": "PipelineReference",
                "referenceName": "MyPipelineName"
            },
            "parameters": {
                "parameter1": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowStartTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "parameter2": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowEndTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "parameter3": "https://mydemo.azurewebsites.net/api/demoapi"
            }
        }
    }
}

下表提供與輪轉視窗觸發程序之週期和排程相關的主要 JSON 元素的概要概觀。

WindowStart 和 WindowEnd 系統變數

您可以在您的 WindowStart (管線) 定義中使用輪轉視窗觸發程序的 WindowEnd 和 系統變數 (也是查詢的一部分)。 在觸發定義中，將系統變數作為參數傳遞到管線。 以下範例示範如何將這些變數當作參數傳遞。

{
    "name": "MyTriggerName",
    "properties": {
        "type": "TumblingWindowTrigger",
            ...
        "pipeline": {
            "pipelineReference": {
                "type": "PipelineReference",
                "referenceName": "MyPipelineName"
            },
            "parameters": {
                "MyWindowStart": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowStartTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "MyWindowEnd": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowEndTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                }
            }
        }
    }
}

若要在管線定義中使用 WindowStart 和 WindowEnd 系統變數值，請據以使用您的 MyWindowStart 和 MyWindowEnd 參數。

回填案例的視窗執行順序

如果觸發程序的 startTime 在過去，則根據此公式 M=(CurrentTime- TriggerStartTime)/TumblingWindowSize，觸發程序會先平行產生 {M} backfill(past) 執行，並接受觸發程序並行，再執行未來的執行。 時間範圍的執行順序具決定性，從最舊到最新的間隔。 目前無法修改此行為。

現有 TriggerResource 元素

下列各點適用於更新現有的 TriggerResource 元素：

• 建立觸發程序後，便無法變更觸發程序的 frequency 元素 (或視窗大小) 以及 interval 元素的值。 若要讓 triggerRun 重新執行和相依性評估正常運作，則此限制為必要。
• 如果觸發程序的 endTime 元素值變更 (新增或更新)，則已經處理的視窗狀態「不會」重設。 觸發程序會採用新的 endTime 值。 如果新的 endTime 值在已經執行的視窗之前，觸發程序會停止。 反之，觸發程序會在遇到新的 endTime 值時停止。

使用者指派的管線重試

如果管線失敗，輪轉視窗觸發程序可以使用相同的輸入參數自動重試參考管線的執行，而不需要使用者介入。 使用觸發程序定義中的 retryPolicy 屬性來指定此動作。

輪轉時間範圍觸發程序相依性

如果您想要確定只有在數據處理站中成功執行另一個輪轉視窗觸發程式之後，才會執行輪轉視窗觸發程式， 請建立輪轉視窗觸發程式相依性。

取消輪轉視窗執行

如果特定視窗處於 [等候中]、[正在等候相依性] 或 [執行中] 狀態，您可以取消輪轉視窗觸發程序的執行：

• 如果視窗處於 [執行中] 狀態，請取消相關聯的 [管線執行]，且觸發程序執行之後會標示為 [已取消]。
• 如果視窗處於 [等候中] 或 [正在等候相依性] 狀態，您可以從 [監視] 取消視窗。

您也可以重新執行已取消的時間範圍。 重新執行會採用觸發程序的最新已發佈定義。 指定視窗的相依性會在重新執行時重新評估。

Azure PowerShell 和 Azure CLI 範例

若要在 Azure 入口網站中監視觸發程序執行和管線執行，請參閱監視管線執行。

相關內容

• 管線執行和觸發程序
• 建立輪轉視窗觸發程序相依性
• 管線執行中的參考觸發程序中繼資料