Azure Synapse中查询无返回行时如何终止关联管道且不报错

核心思路 #

通过Lookup活动获取查询结果行数，结合条件分支控制流程：当查询无数据时，管道A直接正常结束（不触发B、C调用），同时让主管道D也正常终止，全程不使用Fail活动避免误报。

具体实现步骤 #

1. 配置管道A

• 添加Lookup活动：命名为ExtractData，输入你的提取查询，务必勾选允许空结果（Allow empty result），确保查询无返回时不会抛出错误。
• 添加If Condition活动：设置条件表达式为：

  @equals(activity('ExtractData').output.rowsCount, 0)
  

• 配置True分支（无数据场景）：
  • 可添加一个Set Variable活动（可选）：创建布尔型变量ShouldTerminate，赋值为@true()，用于标记终止状态。
  • 此分支无需添加其他活动，执行完后管道A会正常结束，不会调用后续的B、C管道。
• 配置False分支（有数据场景）：
  • 依次添加Execute Pipeline活动，分别调用管道B和管道C，按原有逻辑执行后续流程。

2. 配置主管道D

• 添加Execute Pipeline活动：命名为RunPipelineA，选择管道A，勾选将输出传递给下游活动。
• 添加If Condition活动：设置条件表达式为：

  @equals(activity('RunPipelineA').output.ShouldTerminate, true)
  

• 配置True分支：无需添加任何活动，主管道D会正常终止，不执行后续操作（如果有的话）。
• 配置False分支：添加主管道D原本需要执行的其他后续任务（如果存在）。

关键注意点 #

• 必须确保Lookup活动的「允许空结果」选项处于勾选状态，否则查询无数据时会触发错误，违背需求。
• 若主管道D仅负责调用管道A、无其他后续流程，可省略D中的If Condition：当管道A正常结束（无数据场景），D会自动完成并终止。

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