0

我正在尝试从 Azure 函数向 Azure SignalR 服务发送消息并返回 415，但我不确定如何确定问题的原因。

我已经为应用程序的前端提供了一个工作实现，其中用户和操作能够通过 SignalR 服务广播消息，但是我现在需要一个后端函数来在完成时通知用户。

我遵循的示例是这里的示例； https://github.com/Microsoft/MTC_WhackAMole.NET/blob/master/MoleDeploy.SignalR/AzureSignalR.cs

执行该函数时，它成功完成了 SendAsync() 函数，但实际上并没有触发任何事情。

var payload = new PayloadMessage()
{
    Target = methodName,
    Arguments = args
};
var url = $"{endpoint}/api/v1/hubs/{hubName}";
var bearer = GenerateJwtBearer(null, url, null, DateTime.UtcNow.AddMinutes(30), accessKey);
await PostJsonAsync(url, payload, bearer);

只有在 Postman 中尝试相同的请求时，我才会收到 415 错误。

在 Postman 中，我发布到以下网址；

https://xxxxxx.service.signalr.net/api/v1/hubs/{hubName}

使用不记名身份验证令牌（我知道这是正确的，因为更改它会生成与 415 相对的 401）

它发送以下有效载荷；

{"Target":"hubFunctionName","Arguments":"message to broadcast"}

我不完全确定的是张贴的身体。目标应该是集线器中的功能，而参数应该是要发送的消息吗？

查看在 PostJsonAsync() 中发送的有效负载，结果如下：

payload {AzureFunctionName.AzureSignalR.PayloadMessage}
--Arguments {object[1]}
----[0] "message to broadcast"
--Target    "hubFunctionName"

集线器中的功能非常基础；

public void Send(string messageText)
{
    Clients.All.broadcastMessage(messageText);
}

如果有人能指出我正确的方向，将不胜感激。

谢谢，汤姆

4

2 回答 2

0

根据文档，我认为arguments必须是要发送的消息数组。您能否确认您正在 Postman 中进行相同的测试。

此外，Azure Functions v2 有一个可以直接使用的Azure SignalR 服务输出绑定，而不是自己编写此代码。

于 2019-04-15T09:25:26.813 回答
0

感谢您的回复 - 我想我仍然在努力理解这个功能。

为了扩展，我有一个从队列中读取的基本 Azure 函数，我需要它来向我的信号器服务发送消息。

队列读取是直截了当的（并且有效）

public static void Run([QueueTrigger("signalr-messages", Connection = "Azure.Storage.Main")]string myQueueItem, ILogger log)
{
    <Deserialise>
    SendMessage(message, null);
}

我的 SendMessage 函数看起来像；

public static Task SendMessage(Message message, [SignalR(HubName = "baseHub")]IAsyncCollector<SignalRMessage> signalRMessages)
{
    return signalRMessages.AddAsync(
    new SignalRMessage
      {
        Target = "sendMessage",
        Arguments = new[] { message }
      });
}

我在 SendMessage 中传递“null”但是我知道这是错误的 - 我可以找到的示例来自 HTTP 触发器而不是队列触发器

我什至走上了正确的道路吗？

于 2019-04-15T13:13:23.420 回答