如何用单个触发器在Azure Data Factory单管道分时运行两组不同数据集

核心方案：参数化管道 + 多时段计划触发器 #

这种方式直接可靠，通过触发器传递参数区分两次执行的数据集分组，避免时间判断的误差。

1. 给目标管道添加区分参数
   在ADF管道的"参数"面板中，新建一个字符串类型的参数（例如命名为DatasetGroup），用来标记当前执行要处理的数据集组（比如取值GroupA或GroupB）。

2. 配置数据集的动态逻辑
   针对从数据库获取数据的数据集，通过管道参数动态切换查询或数据源：

   • 如果是SQL查询，直接在查询语句中引用参数：

     -- 示例：根据参数切换查询的表
     SELECT * FROM dbo.@{pipeline().parameters.DatasetGroup}
     

   • 如果是通过筛选条件区分两组数据，可在WHERE子句中加入参数逻辑：

     SELECT * FROM dbo.UnifiedTable 
     WHERE DataCategory = '@{pipeline().parameters.DatasetGroup}'
     

   • 也可以直接在数据集的连接属性（如Schema、表名）中绑定管道参数，实现数据源的动态切换。

3. 创建单计划触发器并配置双时段参数

   • 新建计划触发器，触发频率设为"每日"，在"重复周期"中添加两个需要执行的具体时间点（例如早8:00、晚18:00）。
   • 进入触发器的"管道参数"配置项，为每个执行时段单独设置DatasetGroup的参数值：
     • 早8:00时段：参数值设为GroupA
     • 晚18:00时段：参数值设为GroupB

4. 验证执行效果
   手动触发测试或等待自动执行后，在管道运行历史中查看参数值，确认每次执行都匹配了对应的数据分组；同时检查数据输出结果，确保两组数据集被正确处理。

替代方案：基于执行时间的分支处理 #

如果不想依赖触发器参数，也可以在管道内通过当前时间判断执行分支，但这种方式存在触发器延迟导致判断错误的风险，仅作备选：

• 添加"设置变量"活动，用utcNow()函数获取当前时间并提取小时：

  @utcNow('HH')
  

• 添加"条件分支"活动，根据小时判断进入对应分支：
  • 分支1条件：@and(greaterOrEquals(variables('CurrentHour'), '08'), less(variables('CurrentHour'), '09'))，处理GroupA数据集
  • 分支2条件：@and(greaterOrEquals(variables('CurrentHour'), '18'), less(variables('CurrentHour'), '19'))，处理GroupB数据集

内容的提问来源于stack exchange，提问作者ItsMeS