Azure Data Factory中验证Lookup返回节点并实现读写逻辑的方法

核心思路 #

通过判断Lookup活动输出中是否存在firstRow节点，区分「有数据（更新）」和「无数据（插入）」两个分支，避免节点不存在时的报错。

具体实现步骤 #

1. 添加If Condition活动
   将Lookup活动（GetEmpBySSN）的输出作为判断依据，设置条件表达式：

   @contains(activity('GetEmpBySSN').output, 'firstRow')
   

   • 返回true：说明查询到数据，走更新分支
   • 返回false：说明无匹配数据，走插入分支

2. 更新分支逻辑
   在该分支中直接读取员工编号，用于后续更新操作：

   @activity('GetEmpBySSN').output.firstRow.employee_no
   

3. 插入分支逻辑
   直接执行插入操作即可，无需读取employee_no（无匹配数据时该值不存在）。

补充说明 #

如果希望Lookup活动在无数据时返回更明确的空值标识，可以将Lookup活动的Allow no rows属性设置为true，此时无数据时firstRow会显示为null，但上述contains判断逻辑依然有效。

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