Azure Isolated-Process C#函数实例化Blob Storage Binder遇空引用异常

核心原因 #

你使用的是**.NET Isolated（隔离进程）模式**的Azure Functions，而Binder/IBinder是In-Process（进程内）模式专属的绑定API，隔离模式下不支持该注入逻辑，所以参数binder会被注入null，调用BindAsync时就会抛出NullReferenceException。

解决方案 #

隔离模式下有两种替代方案，按需选择：

方案一：使用内置输出绑定（推荐） #

利用Functions的输出绑定机制，直接定义Blob输出参数，支持动态路径生成：

public class BeaconIngestion
{
    private readonly ILogger<BeaconIngestion> _logger;

    public BeaconIngestion(ILogger<BeaconIngestion> logger)
    {
        _logger = logger;
    }

    [Function(nameof(BeaconIngestion))]
    [StorageAccount("DATA_STORAGE_ACCOUNT_CONNECTION_STRING")]
    public async Task Run(
        [EventHubTrigger("messages/events", Connection = "IOTHUB_CONNECTION_STRING")] EventData[] events,
        // 使用ICollector实现动态多Blob输出
        [Blob("landing/", FileAccess.Write)] ICollector<BlobClient> blobCollectors)
    {
        foreach (var _event in events)
        {
            string message = System.Text.Encoding.UTF8.GetString(_event.Body.ToArray());
            _logger.LogInformation("Event Body: {body}", message);
            _logger.LogInformation("Event Content-Type: {contentType}", _event.ContentType);
            
            // 生成唯一Blob路径
            string blobName = $"{DateTime.UtcNow:yyyy/MM/dd/HH_mm_ss}_{Guid.NewGuid()}.data.json";
            _logger.LogInformation("Sending data to {path}", $"landing/{blobName}");

            var blobClient = blobCollectors.Client.GetBlobClient(blobName);
            await blobClient.UploadAsync(BinaryData.FromString("Hello World"), overwrite: true);
        }
    }
}

方案二：直接使用Azure Blob Storage SDK #

如果需要更灵活的Blob操作逻辑，直接引入SDK手动控制：

1. 安装NuGet包：

Install-Package Azure.Storage.Blobs

2. 修改函数代码，通过依赖注入获取BlobServiceClient：

using Azure.Storage.Blobs;

public class BeaconIngestion
{
    private readonly ILogger<BeaconIngestion> _logger;
    private readonly BlobServiceClient _blobServiceClient;

    public BeaconIngestion(ILogger<BeaconIngestion> logger, BlobServiceClient blobServiceClient)
    {
        _logger = logger;
        _blobServiceClient = blobServiceClient;
    }

    [Function(nameof(BeaconIngestion))]
    public async Task Run(
        [EventHubTrigger("messages/events", Connection = "IOTHUB_CONNECTION_STRING")] EventData[] events)
    {
        // 获取目标容器客户端（自动从配置读取连接字符串）
        var containerClient = _blobServiceClient.GetBlobContainerClient("landing");
        await containerClient.CreateIfNotExistsAsync(); // 确保容器存在

        foreach (var _event in events)
        {
            string message = System.Text.Encoding.UTF8.GetString(_event.Body.ToArray());
            _logger.LogInformation("Event Body: {body}", message);
            _logger.LogInformation("Event Content-Type: {contentType}", _event.ContentType);
            
            string blobPath = $"{DateTime.UtcNow:yyyy/MM/dd/HH_mm_ss}_{Guid.NewGuid()}.data.json";
            _logger.LogInformation("Sending data to {path}", $"landing/{blobPath}");

            var blobClient = containerClient.GetBlobClient(blobPath);
            await blobClient.UploadAsync(BinaryData.FromString("Hello World"), overwrite: true);
        }
    }
}

3. （可选）在Program.cs显式注册BlobServiceClient（默认配置下会自动注册，此步骤可省略）：

using Microsoft.Extensions.Hosting;
using Azure.Storage.Blobs;
using Microsoft.Extensions.Configuration;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddSingleton(sp => 
            new BlobServiceClient(sp.GetRequiredService<IConfiguration>()["DATA_STORAGE_ACCOUNT_CONNECTION_STRING"]));
    })
    .Build();

host.Run();

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