使用Blob触发的独立版Azure Function时，如何将Blob作为Stream获取？

云原生阿岚

2026-8-22

在Azure Functions隔离进程模式中以Stream处理大Blob

隔离进程模式下，默认Blob绑定会将内容加载为ReadOnlyMemory<byte>或string，不适合处理1GB以上的大文件，你可以通过以下两种方案实现流式处理：

方案一：用`BlobClient`按需读取流

直接将BlobTrigger的参数类型改为BlobClient，通过它打开只读流，按需读取Blob内容，不会一次性加载全量数据到内存：

[Function(nameof(Functions.ProcessUpload))]
public void ProcessUpload([BlobTrigger("integration/{name}")] BlobClient blobClient, string name)
{           
    using var stream = blobClient.OpenReadAsync().Result;
    byte[] buffer = new byte[8192];
    int bytesRead;
    while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) > 0)
    {
        // 在这里分块处理读取到的字节内容
    }
}

这种方式灵活性高、完全可控，是处理超大Blob的稳妥方案。

方案二：配置host.json启用流式绑定（.NET 6+）

如果你的Functions运行时是v4及以上（对应.NET 6+），可以通过配置直接启用Blob触发的流式处理：

在host.json中添加如下配置：

{
  "version": "2.0",
  "extensions": {
    "blobs": {
      "trigger": {
        "streamingEnabled": true
      }
    }
  }
}

配置完成后，就能像进程内模式一样直接用Stream作为参数：

[Function(nameof(Functions.ProcessUpload))]
public void ProcessUpload([BlobTrigger("integration/{name}")] Stream blobStream, string name)
{           
    byte[] buffer = new byte[8192];
    int bytesRead;
    while ((bytesRead = blobStream.Read(buffer, 0, buffer.Length)) > 0)
    {
        // 处理流内容逻辑
    }
}