Azure Data Factory中如何在If Condition分支按文件名执行对应管道

方法1：在If Condition的False分支内添加Switch活动 #

这是适配你现有流程的直接方案：

• 移除当前If Condition False分支中同时执行的Pipeline A和Pipeline B，替换为一个Switch活动
• 配置Switch活动的判断表达式为Get File Name活动获取的文件名变量，示例：

  @activity('Get File Name').output.fileName
  

• 为Switch添加两个匹配Case：
  • 第一个Case值设为File A的实际文件名（如'File A.csv'），Case内部添加Execute Pipeline活动调用Pipeline A
  • 第二个Case值设为File B的实际文件名（如'File B.csv'），Case内部添加Execute Pipeline活动调用Pipeline B
• 可设置默认Case为空活动，避免未匹配到文件名时流程报错

方法2：调整现有流程顺序（优化逻辑） #

利用已有的Switch活动，把空判断逻辑拆分到每个文件类型分支中，逻辑更清晰易维护：

• 保留Get File Name活动不变
• 修改原Switch活动的每个Case：
  • File A分支：先执行对应数据流获取行数，紧接着添加If Condition判断行数是否为空，仅在False分支（文件非空）调用Pipeline A
  • File B分支：执行对应数据流获取行数，同样添加If Condition，仅在False分支调用Pipeline B
• 这种方式下，每个文件类型的处理逻辑完全独立，后续新增其他文件类型时扩展性更强

注意事项 #

• 文件名匹配需完全一致（包括后缀、大小写），如果需要忽略大小写，可将表达式转换为小写后匹配：

  @tolower(activity('Get File Name').output.fileName)
  

  对应的Case值也改为小写格式（如'file a.csv'）

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