C# Azure函数EventGrid触发器动态HubName发送SignalR消息

原有HTTP触发的Azure函数可通过SignalR输出绑定的绑定表达式，从查询参数动态获取HubName发送消息，可正常运行的代码如下：

public async Task<IActionResult> Run(
   [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "v1/Sala")] 
HttpRequest req, [SignalR(HubName = "{query.HubName}")] 
IAsyncCollector<SignalRMessage> signalRMessages) {
     
     await signalRMessages.AddAsync(
           new SignalRMessage {
               Target = "newMessage",
               Arguments = new[] { "Hello" }
           });
}

当前需要在EventGrid触发器中实现相同的SignalR消息发送能力，但EventGrid触发器不会被客户端直接调用，无法通过绑定表达式传入动态HubName。目前已经可以在触发器逻辑中通过反序列化事件数据提取到目标HubName，提取逻辑代码如下：

SignalRDataEvent data = 
JsonConvert.DeserializeObject<SignalRDataEvent>(eventGridEvent.Data.ToString());

string hubname = data.hubname;

核心限制：无法在EventGrid触发器的参数上声明带动态HubName配置的[SignalR]特性来绑定IAsyncCollector<SignalRMessage>实例，需要适配C# Azure无服务器函数场景的动态HubName消息发送方案。

不需要手动实现原生SignalR客户端的鉴权、连接维护逻辑，直接使用Azure SignalR Service官方扩展提供的IServiceManager即可实现动态HubName的消息发送，完全适配无服务器函数运行环境。

前置依赖检查 #

• 项目已安装Microsoft.Azure.WebJobs.Extensions.SignalRService 1.7.0及以上版本，使用原有SignalR输出绑定时一般已经满足该依赖要求。
• 函数应用配置中已存在AzureSignalRConnectionString配置项，值为Azure SignalR服务实例的连接字符串，和原有HTTP触发器使用的配置完全一致，无需额外修改。

实现代码（依赖注入方式，推荐） #

通过构造函数注入IServiceManager实例，运行时根据从EventGrid事件中提取的HubName动态创建Hub上下文即可发送消息，完整代码如下：

public class EventGridSignalRSender
{
    private readonly IServiceManager _signalRManager;

    // 扩展自动读取配置中的AzureSignalRConnectionString完成初始化
    public EventGridSignalRSender(IServiceManager signalRManager)
    {
        _signalRManager = signalRManager;
    }

    [FunctionName("SendMessageFromEventGrid")]
    public async Task Run(
        [EventGridTrigger] EventGridEvent eventGridEvent,
        ILogger log)
    {
        // 原有事件解析逻辑
        SignalRDataEvent data = JsonConvert.DeserializeObject<SignalRDataEvent>(eventGridEvent.Data.ToString());
        string hubname = data.hubname;

        // 动态创建对应Hub的上下文
        var hubContext = await _signalRManager.CreateHubContextAsync(hubname);
        
        // 发送消息，写法和原有IAsyncCollector逻辑完全一致
        await hubContext.Clients.All.SendAsync("newMessage", "Hello");
        
        // 释放资源避免连接泄漏
        await hubContext.DisposeAsync();
    }
}

无注入手动初始化方式 #

如果不想使用依赖注入，也可以手动初始化ServiceManager实例，从环境变量读取连接字符串即可，实现代码如下：

[FunctionName("SendMessageFromEventGrid")]
public async Task Run(
    [EventGridTrigger] EventGridEvent eventGridEvent,
    ILogger log)
{
    SignalRDataEvent data = JsonConvert.DeserializeObject<SignalRDataEvent>(eventGridEvent.Data.ToString());
    string hubname = data.hubname;

    // 从环境    var connStr = Environment.GetEnvironmentVariable("AzureSignalRConnectionString");
    var serviceManager = new ServiceManagerBuilder()
        .WithOptions(opt =>
        {
            opt.ConnectionString = connStr;
        })
        .BuildServiceManager();

    var hubContext = await serviceManager.CreateHubContextAsync(hubname);
    await hubContext.Clients.All.SendAsync("newMessage", "Hello");
    await hubContext.DisposeAsync();
}

注意事项 #

• 动态创建的HubContext用完后必须调用DisposeAsync释放资源，避免连接泄漏。
• 消息发送的Target、参数、接收对象范围（广播/指定用户/指定组）的写法和原有输出绑定逻辑完全一致，不需要调整业务消息规则。

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