首页 > 解决方案 > Azure Datafactory - 翻滚窗口触发器

问题描述

我需要按以下方式设置 2 个翻转窗口触发器:第一个每天运行一次(比如早上 7 点)以进行初始加载。第二个为增量加载每 5 分钟运行一次。第二个依赖第一个并且自立。

部署后,第一个根本不会启动,第二个会创建大量运行“等待依赖”。问题是 - 为什么第一个甚至没有开始。

第一个的代码:

{
"name": "tr_once_a_day",
"properties": {
    "description": "The Initialising tumbl window once a day",
    "annotations": [],
    "runtimeState": "Started",
    "pipeline": {
        "pipelineReference": {
            "referenceName": "init_control",
            "type": "PipelineReference"
        },
        "parameters": {
            "Initialise": "1"
        }
    },
    "type": "TumblingWindowTrigger",
    "typeProperties": {
        "frequency": "Hour",
        "interval": 24,
        "startTime": "2021-03-05T20:00:00Z",
        "delay": "00:00:00",
        "maxConcurrency": 50,
        "retryPolicy": {
            "intervalInSeconds": 30
        },
        "dependsOn": []
    }
}

}

{
"name": "tr_every_five_min",
"properties": {
    "description": "runs every 5 min",
    "annotations": [],
    "runtimeState": "Started",
    "pipeline": {
        "pipelineReference": {
            "referenceName": "delta_control",
            "type": "PipelineReference"
        },
        "parameters": {
            "Initialise": "1"
        }
    },
    "type": "TumblingWindowTrigger",
    "typeProperties": {
        "frequency": "Minute",
        "interval": 5,
        "startTime": "2021-03-05T20:30:00Z",
        "delay": "00:00:00",
        "maxConcurrency": 50,
        "retryPolicy": {
            "intervalInSeconds": 30
        },
        "dependsOn": [
            {
                "type": "TumblingWindowTriggerDependencyReference",
                "offset": "-0.00:30:00",
                "referenceTrigger": {
                    "referenceName": "tr_once_a_day",
                    "type": "TriggerReference"
                }
            },
            {
                "type": "SelfDependencyTumblingWindowTriggerReference",
                "size": "0.00:05:00",
                "offset": "-0.00:05:00"
            }
        ]
    }
}

请帮助理解为什么第一个不启动。谢谢你。

标签: triggersazure-data-factory

解决方案


推荐阅读