如何基于Azure SQL DB表全量刷新触发ADF作业并执行SQL块？

针对你的flush and fill全量更新场景，CDC触发器不适用，可通过以下两种方案实现需求：

方案一：基于SQL状态标记触发 #

通过在SQL端添加刷新完成标记，ADF轮询检查标记后触发后续SQL执行：

• 1. 添加状态标记
     在目标表新增LastRefreshCompleted（datetime类型）字段，或创建独立的TableRefreshStatus表（含TableName、IsRefreshCompleted、RefreshEndTime字段）。修改Dynamics DMF的flush and fill作业，在全量填充完成后执行标记更新：

  -- 更新目标表标记字段
  UPDATE [YourTargetTable] SET LastRefreshCompleted = GETDATE();
  
  -- 或更新独立状态表
  UPDATE [TableRefreshStatus] 
  SET IsRefreshCompleted = 1, RefreshEndTime = GETDATE() 
  WHERE TableName = 'YourTargetTable';
  

• 2. 配置ADF管道与触发器
  • 创建ADF管道：先添加Lookup活动，查询状态标记确认刷新完成：

    SELECT IsRefreshCompleted, RefreshEndTime 
    FROM [TableRefreshStatus] 
    WHERE TableName = 'YourTargetTable' 
    AND RefreshEndTime >= DATEADD(MINUTE, -10, GETDATE());
    

  • 添加If Condition活动，判断Lookup返回的IsRefreshCompleted是否为1。
  • 条件满足时，执行SQL Script活动运行目标代码块。
  • 设置轮询触发器（如每5分钟一次），触发管道；执行完成后重置状态标记（如UPDATE [TableRefreshStatus] SET IsRefreshCompleted = 0 WHERE TableName = 'YourTargetTable'），避免重复触发。

方案二：联动Dynamics DMF作业完成事件 #

直接通过DMF作业的完成事件触发ADF管道：

• 1. 配置DMF作业通知
     在Dynamics 365中，为flush and fill作业配置完成后触发Power Automate流。
• 2. 流触发ADF管道
     在Power Automate中，接收DMF作业完成通知后，调用ADF管道运行API，直接触发执行目标SQL代码块的ADF管道。

注意事项 #

• 确保标记更新SQL是DMF作业的最后一步，避免ADF提前触发。
• 根据业务需求调整轮询频率，平衡及时性与资源消耗。

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