如何通过Azure函数读取Azure Blob？触发后OpenRead报引用未找到错误

我之前也遇到过类似的问题，结合Azure函数Blob触发的常见坑，给你几个排查和解决的方向：

1. 检查程序集引用与NuGet包依赖 #

你代码里用了#r "System.IO"，但如果是手动操作Blob对象，还需要确保引用了正确的Azure Storage程序集——不要使用已过时的Microsoft.WindowsAzure.Storage命名空间，建议切换到最新的Microsoft.Azure.Storage.Blob。在C#脚本（.csx）的函数开头添加：

#r "Microsoft.Azure.Storage.Blob"
#r "System.Configuration"

同时要确认你的函数应用已经安装了Azure Storage绑定扩展：本地开发可通过NuGet安装Microsoft.Azure.WebJobs.Extensions.Storage；Azure门户部署的话，在函数应用的「扩展」面板里确认已添加Storage扩展。

2. 优先使用内置Blob绑定（避免手动OpenRead的坑） #

其实Azure函数的Blob触发器已经内置了Stream绑定，不需要你手动调用OpenRead，直接用绑定参数就能拿到文件流，既简单又能避免路径/引用错误。示例如下：

正确的function.json绑定配置 #

{
  "bindings": [
    {
      "name": "inputBlob",
      "type": "blobTrigger",
      "direction": "in",
      "path": "你的容器名称/{name}",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

对应的函数代码 #

using System;
using System.IO;
using Microsoft.Extensions.Logging;

public static void Run(Stream inputBlob, string name, ILogger log)
{
    log.LogInformation($"Processing blob: {name}");
    // 直接读取绑定的Stream
    using (var reader = new StreamReader(inputBlob))
    {
        var content = reader.ReadToEnd();
        log.LogInformation($"Blob content: {content}");
    }
}

3. 如果必须手动操作Blob对象（排查引用未找到的原因） #

如果你一定要手动获取Blob引用并调用OpenRead，请检查以下几点：

• 连接字符串正确性：确保AzureWebJobsStorage环境变量配置的是有效的存储账户连接字符串
• Blob路径准确性：容器名称、Blob文件名（包括路径）不能有拼写错误，注意大小写敏感
• 先检查Blob是否存在：调用OpenRead前先验证Blob存在，避免空引用错误

示例修正后的代码：

#r "Microsoft.Azure.Storage.Blob"
using System;
using System.IO;
using Microsoft.Azure.Storage;
using Microsoft.Azure.Storage.Blob;
using Microsoft.Extensions.Logging;

public static async void Run(ILogger log)
{
    var storageConn = Environment.GetEnvironmentVariable("AzureWebJobsStorage");
    var storageAccount = CloudStorageAccount.Parse(storageConn);
    var blobClient = storageAccount.CreateCloudBlobClient();
    var container = blobClient.GetContainerReference("你的容器名称");
    var targetBlob = container.GetBlockBlobReference("目标Blob文件名");

    // 先检查Blob是否存在
    if (await targetBlob.ExistsAsync())
    {
        using (var stream = await targetBlob.OpenReadAsync())
        {
            using (var reader = new StreamReader(stream))
            {
                var content = reader.ReadToEnd();
                log.LogInformation($"Blob content: {content}");
            }
        }
    }
    else
    {
        log.LogError("Blob引用未找到：目标Blob不存在或路径错误");
    }
}

4. 验证权限配置 #

确保你的函数应用有足够的权限读取Blob：

• 如果使用托管身份：给函数应用的系统分配/用户分配身份添加存储Blob数据读取者角色
• 如果使用连接字符串：确保连接字符串对应的存储账户密钥有Blob读取权限

内容的提问来源于stack exchange，提问作者sreeprasad k s