如何在Azure Data Factory复制活动中获取REST API状态码？

核心思路 #

复制活动无法直接捕获REST API返回的原始状态码（失败时会抛出ADF自身错误），因此需要通过Web活动前置调用API，先获取真实状态码，再通过条件分支实现自定义错误逻辑。

具体实现步骤 #

1. 用Web活动调用API

   • 在管道中添加Web活动，配置与原复制活动完全一致的REST API请求参数（URL、请求方法、headers、查询参数等）。
   • Web活动执行后，会返回完整响应数据，其中包含可直接引用的statusCode字段，示例引用方式：@activity('Web调用API').output.statusCode。

2. 添加条件分支判断状态码

   • 在Web活动后添加If Condition活动，设置三个分支逻辑：
     • 分支1：状态码为404
       • 判断条件：@equals(activity('Web调用API').output.statusCode, 404)
       • 执行逻辑：直接标记管道为成功（可设置变量记录状态，或无操作直接结束）。
     • 分支2：状态码为200（或其他成功状态）
       • 判断条件：@equals(activity('Web调用API').output.statusCode, 200)
       • 执行逻辑：运行原复制活动（可直接复用API配置，或传递Web活动的响应内容作为复制源，避免重复调用）。
     • 分支3：其他状态码
       • 判断条件：@not(or(equals(activity('Web调用API').output.statusCode, 404), equals(activity('Web调用API').output.statusCode, 200)))
       • 执行逻辑：添加Fail活动，设置错误信息，让管道标记为失败。

3. 优化：复用Web活动响应避免重复调用

   • 如果API允许，可将Web活动返回的响应内容直接作为复制活动的源：
     • 复制活动源选择"Inline"类型，内容引用@activity('Web调用API').output，减少一次API调用开销。

为什么不用字符串匹配？ #

Web活动直接返回结构化的statusCode字段，比解析错误消息字符串更可靠，避免因ADF错误消息格式变更导致逻辑失效。

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