Azure Data Factory：如何无失败终止管道执行且不添加额外逻辑？

下面是几个可行的解决办法，直接对应你遇到的问题：

方法1：统一Notebook的输出格式（最直接） #

直接改Notebook的逻辑，当条件不满足时输出空数组，而不是提示字符串。这样ForEach循环拿到空数组会自动跳过执行，管道全程不会报错。
举个PySpark的例子：

if 你的判断条件:
    result = ["待处理项1", "待处理项2"]
else:
    result = []  # 用空数组替代提示文本
dbutils.notebook.exit(result)

方法2：用Set Variable做类型转换 #

1. 在Notebook之后加一个Set Variable活动，新建一个Array类型的变量（比如叫loop_input）。
2. 给变量赋值的表达式写：

   @if(isArray(activity('你的Notebook活动名').output), activity('你的Notebook活动名').output, createArray())
   

   这个表达式会自动判断Notebook的输出：如果是数组就直接用，不是的话就生成空数组。
3. 把ForEach循环的Items设置成这个变量@variables('loop_input')。
   这样不管Notebook输出啥，ForEach拿到的都是合法数组，不会报错。

方法3：正确用If Condition拆分分支 #

你之前说If Condition里放ForEach有问题，应该是层级没弄对。正确操作：

1. 加一个If Condition活动，条件写@isArray(activity('你的Notebook活动名').output)。
2. 条件为True的分支里，直接放你的ForEach循环，传入Notebook的输出数组。
3. 条件为False的分支里，要么啥都不做，要么加个Log活动记录下“条件未满足”的提示就行。
   If Condition的分支里完全可以嵌套ForEach，注意别把活动放错层级就行。

方法4：用Filter活动预处理输出 #

在Notebook和ForEach之间加一个Filter活动：

• 把Filter的Items设为Notebook的输出；
• 过滤条件写@true()（相当于不做过滤）。
  ADF会自动处理输入类型：如果是数组就原封不动返回，是字符串的话直接转成空数组，之后把Filter的输出传给ForEach就行。

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