如何在Azure Data Factory管道成功输出中设置自定义消息或JSON

ADF本身没有直接配置成功状态自定义返回消息的选项，但可以通过以下几种方式实现需求：

方法1：使用Web活动传递自定义输出 #

在管道的最后添加一个Web活动，将需要追加的额外数据（比如运行参数、处理结果统计等）通过活动输出返回。之后查询管道状态时，除了查看顶级的status字段，还可读取该Web活动的输出内容：

• 配置Web活动的方法为GET或POST（若仅返回静态/计算数据，用GET并在正文构造JSON即可）
• 在Web活动的正文里编写自定义JSON，例如：

  {
    "status": "Success",
    "customData": {
      "processedRows": 1000,
      "runId": "@pipeline().RunId",
      "finishTime": "@utcNow()"
    }
  }
  

• 调用REST API查询管道运行详情时，在activities数组中找到这个Web活动，提取其output字段即可获取自定义数据。

方法2：利用管道变量和输出属性 #

在管道中定义变量存储需要追加的数据，最后通过设置管道的输出属性暴露这些变量：

1. 在管道中创建变量（比如var_processedCount），在活动执行过程中更新变量值
2. 进入管道的设置页，找到输出区域，添加自定义输出属性：

   {
     "customSuccessData": {
       "totalItems": "@variables('var_processedCount')",
       "pipelineName": "@pipeline().PipelineName"
     }
   }
   

3. 查询管道运行状态的REST API响应中，output字段会包含你定义的自定义数据，和默认的status字段一同返回。

方法3：通过存储账户持久化额外数据关联查询 #

如果不需要直接在REST响应中返回，而是需要关联成功状态查询额外数据，可以：

• 在管道成功完成时，使用Copy活动或Azure Function活动将自定义数据写入Blob存储
• 查询管道状态时，根据RunId关联查询存储中的对应数据，拼接成完整结果。

这些方法都能绕过ADF原生成功状态无自定义消息的限制，按需追加所需的额外数据。

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