.NET 8升级后ServicebusTrigger未识别，如何重构为隔离式Worker？

在隔离式Worker模型中，不能使用WebJobs的ServiceBusTrigger作为输出绑定，需要改用Azure官方的Azure.Messaging.ServiceBus SDK直接实现消息发送。以下是重构后的代码及关键说明：

1. 安装依赖包 #

确保项目已安装以下NuGet包：

• Microsoft.Azure.Functions.Worker（隔离式Worker核心包）
• Azure.Messaging.ServiceBus（Service Bus官方SDK）

2. 重构后的代码 #

using Azure.Messaging.ServiceBus;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

public class YourFunctionClass
{
    private readonly ServiceBusClient _serviceBusClient;
    private readonly TelemetryClient _telemetryClient;
    private readonly IHttpClientService _httpClientService;
    private readonly IConfiguration _config;
    private readonly string _buildingsTopicName;

    // 通过构造函数注入依赖
    public YourFunctionClass(ServiceBusClient serviceBusClient, 
                             TelemetryClient telemetryClient,
                             IHttpClientService httpClientService,
                             IConfiguration config)
    {
        _serviceBusClient = serviceBusClient;
        _telemetryClient = telemetryClient;
        _httpClientService = httpClientService;
        _config = config;
        // 从配置中读取主题名
        _buildingsTopicName = config["ServiceBusBuildingsTopic"];
    }

    public async Task PublishBuildingsDifferences(
        [ActivityTrigger] IEnumerable<Difference> differences)
    {
        // 创建ServiceBusSender，用于发送消息到指定主题
        using var sender = _serviceBusClient.CreateSender(_buildingsTopicName);
        try
        {
            using (var timer = new MetricTimer(_telemetryClient, TelemetryConstants.BuildingsPublishDifferencesTime))
            {
                // 将差异对象转换为ServiceBusMessage集合
                var messages = differences.Select(d => d.ToServiceBusMessage()).ToList();
                
                // 批量发送消息（也可逐个调用SendMessageAsync）
                if (messages.Any())
                {
                    await sender.SendMessagesAsync(messages);
                }

                _telemetryClient.TrackTrace(TelemetryConstants.BuildingsDifferencesPublished, new Dictionary<string, string>()
                {
                    { "Total records", differences.Count().ToString() },
                });
            }
        }
        catch (Exception e)
        {
            _httpClientService.HttpPostErrorHandlingFunctionApp(_config, "", e, 1, IssueType.Integration);
            var wrapped = new PublishDifferencesException(e);
            _telemetryClient.TrackException(wrapped);

            throw wrapped;
        }
    }
}

3. 关键变化说明 #

• 移除ServiceBusTrigger输出绑定：隔离式Worker不支持WebJobs风格的输出绑定，改用SDK直接操作Service Bus。
• 依赖注入ServiceBusClient：在Program.cs中注册ServiceBusClient，通过构造函数注入到函数类中：

  // Program.cs中的配置代码
  var builder = Host.CreateDefaultBuilder(args);
  builder.ConfigureFunctionsWorkerDefaults();
  // 注册ServiceBusClient，从配置读取连接字符串
  builder.Services.AddServiceBusClient(builder.Configuration["ServiceBusConnectionString"]);
  

• 使用ServiceBusSender发送消息：通过CreateSender方法创建对应主题的发送器，支持批量或单条发送消息，替代原来的IAsyncCollector。
• 保留原有业务逻辑：异常处理、遥测追踪等逻辑保持不变，仅替换消息发送的实现方式。

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