如何在Azure Function中运行基于自定义事件触发的ADF复制活动管道

方案1：Azure Function调用ADF HTTP触发端点 #

这种方式适合需要在Function中处理额外业务逻辑后再触发管道的场景，步骤如下：

• 给ADF复制管道配置HTTP触发器
  在ADF门户打开目标管道，添加「HTTP触发器」，选择合适的授权方式（推荐用托管标识或SAS令牌），保存后记录触发器的请求URL。
• 在Azure Function中编写触发逻辑
  以Python为例，编写Function代码调用ADF的HTTP触发端点：

  import requests
  import os
  from azure.identity import DefaultAzureCredential
  
  def main(req):
      # 从环境变量读取ADF触发URL
      adf_trigger_url = os.environ["ADF_TRIGGER_URL"]
      credential = DefaultAzureCredential()
      # 获取ADF的访问令牌（托管标识授权场景）
      token = credential.get_token("https://management.azure.com/.default").token
      headers = {"Authorization": f"Bearer {token}"}
      
      try:
          response = requests.post(adf_trigger_url, headers=headers)
          response.raise_for_status()
          return {"status": "success", "message": "管道已成功触发"}
      except requests.exceptions.HTTPError as err:
          return {"status": "failed", "error": str(err)}
  

  把ADF触发URL等敏感信息存到Function的环境变量中，避免硬编码。
• 给Function配置事件触发源
  如果需要通过自定义事件触发Function，给Function添加「事件网格触发器」，订阅Blob存储的事件（比如Blob创建/修改事件），并设置过滤规则，只响应输入文件夹内的Blob操作事件。当事件触发Function后，自动执行上述代码调用ADF管道。

方案2：直接用事件网格触发ADF管道（无需Function中转） #

如果不需要在Function中处理额外逻辑，可以跳过Function，直接用ADF的「事件网格触发器」订阅Blob存储的事件：

• 在ADF中给复制管道添加「事件网格触发器」，选择目标Blob存储账户，设置事件类型（比如BlobCreated），并配置文件夹过滤规则（指定输入文件夹路径）。
• 当输入文件夹有新Blob上传时，事件网格会直接触发ADF复制管道，完成文件复制。

关键注意事项 #

• 权限配置：确保Function的托管标识拥有ADF的「Data Factory Contributor」角色，或者HTTP触发器的授权凭证有效，避免调用失败。
• 错误处理：在Function中添加重试机制和日志记录，便于排查管道触发失败的问题。
• 事件过滤：无论是Function的事件网格触发器还是ADF的事件网格触发器，都要设置精确的文件夹过滤规则，避免无效触发。

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