在隔离式Azure Functions中为Service Bus输出消息设置标签

场景与问题 #

我正在开发基于.NET 7的隔离进程Azure函数，代码如下：

[Function(nameof(ClassName))]
[ServiceBusOutput("queue1", Connection = "ServiceBusConnection")]
public async Task<string> Run([ServiceBusTrigger("queue2", Connection = "ServiceBusConnection")] string input)
{
    return await ExecuteFunctionCore(input);
}

在此场景下我能否设置subject/label？由于存在已知的Body解析问题，我无法使用ServiceBusMessage类。

可行解决方案 #

可以通过以下几种方式设置Subject/Label，同时避开Body解析问题：

方案一：静态属性配置（适用于固定值） #

直接在ServiceBusOutput特性中通过Properties参数指定静态的Subject值：

[ServiceBusOutput("queue1", Connection = "ServiceBusConnection", Properties = "{\"Subject\": \"固定主题值\"}")]

这种方式无需修改返回类型，适合Subject值固定的场景。

方案二：使用MessageData类型（推荐） #

改用MessageData作为返回类型，它允许你设置消息属性同时避免Body解析问题：

using Microsoft.Azure.Functions.Worker.ServiceBus;

[Function(nameof(ClassName))]
[ServiceBusOutput("queue1", Connection = "ServiceBusConnection")]
public async Task<MessageData> Run([ServiceBusTrigger("queue2", Connection = "ServiceBusConnection")] string input)
{
    var result = await ExecuteFunctionCore(input);
    var messageData = MessageData.FromString(result);
    messageData.Message.Subject = "动态主题值";
    return messageData;
}

注意：需要确保安装的Microsoft.Azure.Functions.Worker.Extensions.ServiceBus NuGet包版本在5.11.0及以上，该版本对MessageData的支持更完善。

方案三：使用异步收集器（灵活控制） #

如果需要处理多条消息或更灵活的消息配置，可以注入IAsyncCollector<ServiceBusMessage>，通过字节数组传递Body来避开解析问题：

using Azure.Messaging.ServiceBus;
using System.Text;

[Function(nameof(ClassName))]
public async Task Run(
    [ServiceBusTrigger("queue2", Connection = "ServiceBusConnection")] string input,
    [ServiceBusOutput("queue1", Connection = "ServiceBusConnection")] IAsyncCollector<ServiceBusMessage> outputCollector)
{
    var result = await ExecuteFunctionCore(input);
    var message = new ServiceBusMessage(Encoding.UTF8.GetBytes(result))
    {
        Subject = "自定义主题值"
    };
    await outputCollector.AddAsync(message);
}

这种方式直接构造ServiceBusMessage，但通过字节数组而非字符串传递Body，规避了字符串解析引发的问题。

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