在C#独立工作进程中用ServiceBusOutput绑定能否设置ServiceBusMessage的ApplicationProperties？

你遇到的问题是独立工作进程模式下，ServiceBusOutput绑定对ServiceBusMessage类型的处理问题，并非无法实现，以下是可行的解决方法和排查点：

1. 确认ServiceBus扩展版本 #

确保项目中引用的Microsoft.Azure.Functions.Worker.Extensions.ServiceBus版本不低于5.11.0，早期版本对ServiceBusMessage类型的输出绑定支持存在缺陷。查看项目文件中的引用：

<PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.ServiceBus" Version="5.11.0" />

2. 配置ServiceBus输出绑定的序列化器 #

独立工作进程默认的JSON序列化器会将整个ServiceBusMessage对象序列化为消息体，需要在Program.cs中指定使用原生的ServiceBus消息序列化逻辑：

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.Configure<ServiceBusOutputBindingOptions>(options =>
        {
            // 使用原生序列化器，直接识别ServiceBusMessage的结构
            options.Serializer = ServiceBusMessageSerializer.Default;
        });
    })
    .Build();

host.Run();

添加此配置后，你的原有代码（返回包含ServiceBusMessage的输出对象）就能正确发送消息体和ApplicationProperties。

3. 替代方案：使用IAsyncCollector手动发送 #

如果上述配置仍未解决问题，可以改用IAsyncCollector<ServiceBusMessage>直接控制消息发送，这种方式更灵活且避免序列化歧义：
修改函数实现如下：

[Function("ListenerFunction")]
public async Task Run(
    [ServiceBusTrigger("%Topic%", "%Subscription%", Connection = "connection", IsSessionsEnabled = false)] ServiceBusMessageWithBlobUrl serviceBusMessageWithBlobUrl,
    [BlobInput("{UploadedBlobUrl}", Connection = "blobConnection")] Entity entity,
    [CosmosDBOutput(databaseName: "%database%", containerName: "%container%", Connection = "databaseConnection")] out Entity cosmosDbDocument,
    [ServiceBusOutput("%topic%", EntityType = ServiceBusEntityType.Topic, Connection = "connection")] IAsyncCollector<ServiceBusMessage> serviceBusMessages,
    FunctionContext context)
{
    _logger.LogInformation("C# ServiceBus topic trigger function processed message: {inputMaterialEventServiceBusMessage}", serviceBusMessageWithBlobUrl.ToString());

    var id = Guid.NewGuid();
    // 处理CosmosDB输出
    cosmosDbDocument = entity with { Id = id};

    // 构造带属性的ServiceBus消息
    var notificationContent = JsonConvert.SerializeObject(
        new EntityNotification(id, serviceBusMessageWithBlobUrl.CorrelationId, cosmosDbDocument), 
        Formatting.Indented);
    var serviceBusMessage = new ServiceBusMessage(notificationContent);
    serviceBusMessage.ApplicationProperties.Add("Type", "Type1");

    // 发送消息
    await serviceBusMessages.AddAsync(serviceBusMessage);
}

这种方式无需返回复杂输出对象，直接通过out参数处理CosmosDB写入，IAsyncCollector负责发送带属性的ServiceBus消息。

4. 验证结果 #

发送消息后，可在Azure Portal的Service Bus主题中查看消息详情：

• 进入目标主题 → 选择「消息」→ 点击具体消息 → 切换到「应用属性」标签查看是否包含Type: Type1，同时检查「消息正文」是否为预期内容。

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