如何在隔离式Service Bus触发器Azure函数中间件中访问队列名称

在隔离式Azure Functions模型中，要在自定义中间件里拿到消息的源队列/主题名称，最直接的方式是从ServiceBusReceivedMessage实例中提取EntityPath属性，这个属性就对应消息的来源实体名称（队列或主题）。

实现步骤： #

• 在中间件的InvokeAsync方法中，通过FunctionContext的Bindings集合获取触发器绑定的ServiceBusReceivedMessage对象。Bindings的键名对应你函数中Service Bus触发器参数的名称（比如函数参数是ServiceBusReceivedMessage message，键就是message）。
• 从ServiceBusReceivedMessage中读取EntityPath属性，即为源队列/主题名称。

代码示例： #

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Middleware;
using Azure.Messaging.ServiceBus;
using System.Linq;

public class ServiceBusQueueMiddleware : IFunctionsWorkerMiddleware
{
    public async Task InvokeAsync(FunctionContext context, FunctionExecutionDelegate next)
    {
        // 方式1：通过参数名称直接获取
        if (context.Bindings.TryGetValue("message", out var bindingValue) 
            && bindingValue is ServiceBusReceivedMessage sbMessage)
        {
            string sourceQueueName = sbMessage.EntityPath;
            // 这里可以加入你的业务逻辑，比如日志记录、权限验证等
        }

        // 方式2：遍历绑定值，兼容不同参数名称
        // var sbMessage = context.Bindings.Values
        //     .FirstOrDefault(v => v is ServiceBusReceivedMessage) as ServiceBusReceivedMessage;
        // if (sbMessage != null)
        // {
        //     string sourceQueueName = sbMessage.EntityPath;
        // }

        await next(context);
    }
}

注意事项： #

• 确保你的函数触发器参数类型是ServiceBusReceivedMessage（而非string或其他类型），这样才能从绑定数据中拿到完整的消息对象。
• 如果你使用了批量触发器（ServiceBusReceivedMessage[]），需要遍历数组中的每个消息，分别获取EntityPath（批量消息来自同一个队列/主题的话，所有消息的EntityPath是一致的）。

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