ADF中CSV转MongoDB迁移完成后触发API的可行性与配置方法问询

1. 给现有管道添加Web活动 #

打开你用来把CSV转存到MongoDB的管道，在活动面板的「通用」分类里找到「Web」活动，拖到画布上，把它放在数据迁移的核心活动（比如Copy活动）的后面，设置依赖关系为成功时触发——这样只有当数据迁移顺利完成，才会调用API。

2. 配置Web活动的API触发细节 #

进入Web活动的「设置」标签页，按你的API需求填写参数：

• URL：填你的微服务API地址或者Azure Function的调用地址（如果是Azure Function，记得带上访问密钥，格式大概是https://<函数应用名>.azurewebsites.net/api/<函数名>?code=<访问密钥>）。
• 请求方法：根据API的要求选GET、POST或者其他，一般触发类操作常用POST。
• 请求正文（可选）：如果需要给API传迁移相关的元数据（比如迁移了多少条记录、源文件名），可以用动态内容生成JSON，比如：

  {
    "source_file": "@pipeline().parameters.SourceFileName",
    "copied_rows": "@activity('你的Copy活动名称').output.rowsCopied",
    "status": "success"
  }
  

• 身份验证（可选）：如果API需要验证，选对应的方式（比如Azure AD、API密钥、基础认证），填好凭据就行。

3. 可选：配置失败时的API通知 #

要是你想在迁移失败时也通知API，可以再拖一个Web活动，设置依赖关系为失败时触发，然后在请求正文里传错误信息，比如：

{
  "source_file": "@pipeline().parameters.SourceFileName",
  "error_msg": "@activity('你的Copy活动名称').error.message",
  "status": "failed"
}

4. 测试验证 #

触发管道运行，等迁移完成后，查看Web活动的运行日志，确认API有没有被成功调用；同时去API端检查接收记录，看看参数是不是正确传过去了。

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