如何在Azure Data Factory中用If Condition/Lookup实现as_of_date分支逻辑？

方案合理性 #

Lookup+CASE WHEN的方案完全可行，甚至在复杂判断场景下比直接用IF Condition更灵活。它通过SQL查询直接生成明确的分支标识，后续逻辑直接基于这个结果执行，既避免了在ADF表达式中写复杂判断，也能把业务规则封装在SQL里，后续修改规则只需调整SQL，不用改动ADF的活动配置。如果后续需要复用判断结果，Lookup的输出也能在整个管道中直接引用。

实现步骤 #

1. 配置Lookup活动 #

• 新建Lookup活动，关联目标SQLDB的数据源
• 编写带CASE WHEN的查询语句，生成分支判断结果，示例SQL：

SELECT 
    CASE 
        -- 判断表中最新的as_of_date是否为上月末
        WHEN MAX(as_of_date) = '2023-05-31' THEN 'CopyToLake'
        ELSE 'RunFailSP'
    END AS ActionToExecute
FROM [你的目标表名]

注：如果需要验证所有as_of_date都是2023-05-31，可修改SQL为：

SELECT 
    CASE 
        WHEN COUNT(*) = COUNT(CASE WHEN as_of_date = '2023-05-31' THEN 1 END) THEN 'CopyToLake'
        ELSE 'RunFailSP'
    END AS ActionToExecute
FROM [你的目标表名]

• 保持Lookup活动默认的「First row only」勾选状态，确保只返回一行结果，方便后续引用。

2. 配置分支逻辑 #

推荐用Switch活动（比IF Condition更适配明确值分支的场景），也可以继续用IF Condition：

方式一：用Switch活动

• 切换表达式设置为：@{activity('Lookup判断as_of_date').output.firstRow.ActionToExecute}
• 添加两个分支：
  • 分支值填CopyToLake，将「Copy to Lake From SQLDB」活动拖入该分支
  • 分支值填RunFailSP，将「Stored Procedure Fail Process」存储过程活动拖入该分支
  • 可选添加默认分支，处理未预期的判断结果

方式二：用IF Condition活动

• 条件表达式设置为：@{equals(activity('Lookup判断as_of_date').output.firstRow.ActionToExecute, 'CopyToLake')}
• True分支放置「Copy to Lake From SQLDB」活动，False分支放置「Stored Procedure Fail Process」活动

与直接IF Condition方案的对比 #

直接用IF Condition的话，本质也是先通过Lookup获取as_of_date，再在表达式里判断是否等于目标日期。而Lookup+CASE WHEN的区别是把判断逻辑移到了SQL中，更适合多条件组合的复杂判断，后续修改规则只需调整SQL，不用修改ADF的表达式配置，维护性更强。

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