创建按翻转窗口运行管道的触发器

适用于：Azure 数据工厂 Azure Synapse Analytics

本文提供了创建、启动和监视翻转窗口触发器的步骤。 有关触发器和支持的类型的一般信息，请参阅管道执行和触发器。

翻转窗口触发器是一类可以在保留状态的同时按周期性的时间间隔（从指定的开始时间算起）触发的触发器。 翻转窗口是一系列固定大小、非重叠且连续的时间间隔。 翻转窗口触发器与管道存在一对一关系，一个这样的触发器只能引用一个管道。

翻转窗口触发器是计划触发器的更重量级的替代方法。 它提供了一套适用于复杂方案（例如，其他翻转窗口触发器上的依赖项、重新运行失败的作业，以及为管道设置用户重试）的功能。 若要进一步了解计划触发器与翻转窗口触发器之间的差异，请参阅触发器类型比较。

Azure 数据工厂和 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.chinacloudsites.cn/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 门户中监视触发器运行和管道运行，请参阅监视管道运行。

相关内容

• 管道执行和触发器
• 创建翻转窗口触发器依赖项
• 在管道运行中引用触发器元数据