Azure Data Factory：如何通过Web Activity发送Lookup Activity输出邮件？

核心问题定位 #

Web Activity报错通常和动态表达式解析错误、邮件API请求格式/权限问题有关，结合你的管道逻辑，从以下环节逐一排查：

1. 确认Lookup活动的输出结构 #

先确保Lookup的SQL语句返回预期结果，比如统计NULL行数的SQL示例：

SELECT COUNT(*) AS NullRowCount FROM YourTargetTable WHERE TargetColumn IS NULL

此时Lookup的标准输出结构应为：

{
  "value": [
    {
      "NullRowCount": 123  -- 实际统计的NULL行数
    }
  ],
  "count": 1
}

你可以在ADF监控页面查看Lookup活动的Output标签，验证该结构是否正确。

2. 简化管道逻辑（移除不必要的ForEach） #

由于Lookup返回的是单条统计结果，完全不需要ForEach循环，直接引用结果即可，能避免循环内的变量赋值错误。

3. Web Activity的正确配置 #

假设你使用SendGrid/Office 365等HTTP邮件API，按以下步骤配置：

• 方法：选择POST
• URL：填写邮件服务的API地址（例如SendGrid的https://api.sendgrid.com/v3/mail/send）
• Headers：添加必要请求头，示例：
  • Content-Type: application/json
  • Authorization: Bearer 你的API密钥（SendGrid场景）
• Body：构造符合API要求的JSON格式，嵌入Lookup统计结果：

{
  "personalizations": [
    {
      "to": [{"email": "接收人邮箱@xxx.com"}],
      "subject": "数据同步后NULL值统计报告"
    }
  ],
  "from": {"email": "发件人邮箱@xxx.com"},
  "content": [
    {
      "type": "text/plain",
      "value": "本次数据同步完成后，指定列的NULL值行数为：@{activity('Lookup1').output.value[0].NullRowCount}"
    }
  ]
}

注意：动态表达式必须用@{}包裹，且需正确指向Lookup输出的数组元素（value[0]）。

4. 报错排查步骤 #

若Web Activity仍报错，按以下方式定位：

• 查看Web Activity的Input标签：确认请求URL、Headers、Body是否符合预期，尤其是动态表达式是否解析出正确行数
• 查看Web Activity的Output标签：里面会返回具体错误信息（例如401=权限验证失败，400=请求格式错误，500=API服务端错误）
• 用Postman/curl单独测试邮件API：先确保API本身能正常发邮件，再将正确参数复制到ADF中

5. 保留ForEach的配置注意事项 #

如果一定要保留ForEach循环，需注意：

• ForEach的Items设置为@activity('Lookup1').output.value是正确的
• 循环内的Set Variable活动，变量表达式用@item().NullRowCount（对应Lookup输出的字段名）
• Web Activity中引用变量时，用@{variables('你的变量名')}

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