Azure Function v4隔离进程：ServiceBusTrigger订阅创建及异常处理

问题场景 #

使用.NET Isolated（进程外）Azure Function v4，通过ServiceBusTrigger监听Service Bus消息。在Program.cs中用HostBuilder配置依赖注入，启动时尝试先创建订阅，但触发器会在订阅创建完成前就发起Service Bus连接请求，导致大量如下错误：

[2023-02-13T] System.Private.CoreLib: The messaging entity ':Topic:my-topic|my-sub' could not be found. TrackingId:2c20, SystemTracker:'Topic:my-topic|my-sub', Timestamp:2023-02-13T15:12:36 TrackingId:043a, SystemTracker:gateway7, Timestamp:2023-02-13T15:12:36 (MessagingEntityNotFound).

解决方案 #

核心目标是确保订阅创建完成后，再初始化ServiceBusTrigger的连接逻辑，以下两种方法可实现：

方法1：延迟触发器初始化，先完成订阅创建 #

先构建Host但不立即运行，手动获取服务实例完成订阅创建后，再启动触发器的执行服务：

var host = new HostBuilder()
    .ConfigureAppConfiguration(builder =>
    {
        // 你的配置逻辑（如读取环境变量、配置文件）
    })
    .ConfigureServices((context, services) =>
    {
        // 注册自定义服务
        services.AddSingleton<ServiceBusAdmin>();
        // 注册Function Worker基础服务
        services.AddFunctionsWorkerDefaults();
    })
    .Build();

// 先执行订阅创建逻辑
var serviceBusAdmin = host.Services.GetRequiredService<ServiceBusAdmin>();
await serviceBusAdmin.CreateOrUpdateAzureServiceBusSubscriptionsAsync();

// 手动启动触发器执行服务
var functionExecutor = host.Services.GetRequiredService<Microsoft.Azure.Functions.Worker.IFunctionExecutor>();
await functionExecutor.StartAsync(CancellationToken.None);

await host.RunAsync();

方法2：使用HostedService在启动阶段优先创建订阅 #

通过实现IHostedService，将订阅创建逻辑嵌入Host启动流程，确保其在触发器初始化前执行：

1. 创建订阅初始化服务：

public class SubscriptionSetupService : IHostedService
{
    private readonly ServiceBusAdmin _serviceBusAdmin;

    public SubscriptionSetupService(ServiceBusAdmin serviceBusAdmin)
    {
        _serviceBusAdmin = serviceBusAdmin;
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        // 在Host启动时执行订阅创建
        await _serviceBusAdmin.CreateOrUpdateAzureServiceBusSubscriptionsAsync();
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        return Task.CompletedTask;
    }
}

2. 在HostBuilder中注册该服务：

var host = new HostBuilder()
    .ConfigureAppConfiguration(builder =>
    {
        // 你的配置逻辑
    })
    .ConfigureServices((context, services) =>
    {
        services.AddSingleton<ServiceBusAdmin>();
        // 注册订阅初始化服务，Host会优先执行它的启动逻辑
        services.AddHostedService<SubscriptionSetupService>();
        services.AddFunctionsWorkerDefaults();
    })
    .Build();

await host.RunAsync();

额外优化建议 #

• 在CreateOrUpdateAzureServiceBusSubscriptionsAsync中添加异常捕获与日志记录，避免订阅创建失败导致Host启动异常；
• 配置ServiceBusTrigger的重试策略，即使初始化时遇错，后续也能自动重试连接，在host.json中添加：

{
  "version": "2.0",
  "extensions": {
    "serviceBus": {
      "retryOptions": {
        "mode": "exponential",
        "maxRetries": 5,
        "maxDelay": "00:00:30",
        "minimumBackoff": "00:00:01"
      }
    }
  }
}

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