如何使用Azure函数在Singlr客户端中设置用户ID

Question

我有一个由Azure Blob存储触发的SignalR的Azure函数应用程序。 BLOB文件的名称是SignalR客户端的用户ID，它应该在其中接收文件的内容。当触发Azure功能应用程序时，应将消息发送给特定客户端。如何在客户端设置用户ID以实现此情况？ Azure函数应用程序是C＃应用，而客户端应用程序既是C＃又是Angular。

当userId中的signalrmessage设置为空字符串，它将成功发送给所有客户端。但是我需要发送给具有匹配用户ID的特定客户端。

这是我所做的：

[服务器/功能应用]

[FunctionName("BlobTringgeredFunction")]
public async Task Run([BlobTrigger("file-pro/{name}")]Stream myBlob,
    string name, 
    ILogger log,
    [SignalR(HubName = "filehub")] IAsyncCollector<SignalRMessage> signalRMessages)
{
    log.LogInformation($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myBlob.Length} Bytes");
    
    var receiver = name.Split('.').First();
    var responseText = GetJson(myBlob); //get myBlob content and covert it to json text

    await signalRMessages.AddAsync(
        new SignalRMessage
        {
            UserId = receiver,
            Target = "newMessage",
            Arguments = new[] { responseText }
        });
}

[客户端]

在哪里设置用户ID？

var token = await GetToken();
connection = new HubConnectionBuilder()
.WithUrl(txtConnect.Text, options =>
{
    options.AccessTokenProvider = () => Task.FromResult(token);
})
.Build();

connection.On<string>("newMessage", (message) =>
{
    WriteLog(message);
    //do something here
});

await connection.StartAsync();

Answer 1

可以将 userId 添加到getToken函数的URL查询参数中，以传递到 signalrconnectioninfo 输入绑定，请参见我的示例：

    {
      "bindings": [
      {
        "authLevel": "function",
        "name": "req",
        "type": "httpTrigger",
        "direction": "in",
        "methods": [
          "get"
        ]
      },
      {
        "type": "signalRConnectionInfo",
        "name": "connectionInfo",
        "hubName": "%AzureSignalRHubName%",
        "connectionStringSetting": "AzureSignalRConnectionString",
        "userId": "{query.userid}",
        "direction": "in"
      },
      {
        "name": "$return",
        "type": "http",
        "direction": "out"
      }
     ]
   }