如何在Azure Data Factory管道中调用Blob触发型Azure Function

方案1：为Azure Function新增HTTP触发入口（最小改动） #

保留原有Blob触发逻辑的同时，在同一个Function App内新增一个HTTP触发的函数，让它调用原函数的核心业务逻辑，这样ADF就能通过HTTP请求触发执行。

• 核心思路：将原Blob触发函数的业务逻辑抽离为独立方法，新增HTTP触发函数接收ADF传入的Blob参数（容器名、Blob路径），获取Blob流后调用抽离的业务逻辑。
• 示例代码（C#）：

  // 原Blob触发函数（保留不变）
  public static async Task RunBlobTrigger(
      [BlobTrigger("your-container/{name}", Connection = "AzureWebJobsStorage")] Stream myBlob, 
      string name, 
      ILogger log)
  {
      await ProcessBlobBusinessLogic(name, myBlob, log);
  }
  
  // 新增供ADF调用的HTTP触发函数
  [FunctionName("HttpTriggerForADF")]
  public static async Task<IActionResult> RunHttpTrigger(
      [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
      ILogger log)
  {
      // 解析ADF传入的参数
      var requestBody = await new StreamReader(req.Body).ReadToEndAsync();
      var param = JsonConvert.DeserializeObject<BlobParam>(requestBody);
      
      if (string.IsNullOrEmpty(param.ContainerName) || string.IsNullOrEmpty(param.BlobName))
      {
          return new BadRequestObjectResult("缺少必要参数：ContainerName 或 BlobName");
      }
  
      // 获取目标Blob流
      var storageAccount = CloudStorageAccount.Parse(Environment.GetEnvironmentVariable("AzureWebJobsStorage"));
      var blobClient = storageAccount.CreateCloudBlobClient();
      var container = blobClient.GetContainerReference(param.ContainerName);
      var blob = container.GetBlockBlobReference(param.BlobName);
      
      using (var blobStream = new MemoryStream())
      {
          await blob.DownloadToStreamAsync(blobStream);
          blobStream.Position = 0;
          // 调用核心业务逻辑
          await ProcessBlobBusinessLogic(param.BlobName, blobStream, log);
      }
  
      return new OkObjectResult("Blob处理完成");
  }
  
  // 抽离的核心业务逻辑方法
  private static async Task ProcessBlobBusinessLogic(string blobName, Stream blobStream, ILogger log)
  {
      // 原复杂业务逻辑代码移至此处
  }
  
  // 参数模型类
  public class BlobParam
  {
      public string ContainerName { get; set; }
      public string BlobName { get; set; }
  }
  

• ADF配置：使用Azure Function活动，选择POST方法，在请求体中传入ContainerName和BlobName，函数密钥填写Function App的访问密钥。

方案2：将触发逻辑移至ADF，改为HTTP触发型函数 #

如果允许调整原有触发方式，可取消Azure Function的Blob触发器，改用ADF的Blob事件触发器触发管道，管道中调用HTTP触发的函数处理业务：

• 配置ADF Blob事件触发器，监听目标容器的Blob创建/修改事件。
• 管道中添加Azure Function活动，调用改为HTTP触发的目标函数，传入触发器捕获的Blob路径、容器名等参数。
• 此方案将触发调度逻辑统一到ADF，函数仅负责业务处理。

方案3：用Logic Apps作为中间层调度 #

通过Logic Apps封装调用逻辑，ADF调用Logic Apps的HTTP端点，由Logic Apps完成Blob获取与函数调用：

• 创建Logic Apps，添加HTTP触发器（设置允许ADF调用的权限）。
• 添加「Azure Blob Storage」动作，根据ADF传入的参数获取Blob内容。
• 添加「Azure Functions」动作，调用原函数的业务逻辑（或直接在Logic Apps中复用核心逻辑）。
• ADF使用Web活动调用Logic Apps的HTTP端点，传入必要的Blob参数。

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