I have install Microsoft.Azure.WebJobs.Extensions.SignalRService using extensions.csproj.
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework>
<WarningsAsErrors />
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Azure.WebJobs.Extensions.CosmosDB" Version="3.0.1" />
<PackageReference Include="Microsoft.Azure.WebJobs.Script.ExtensionsMetadataGenerator" Version="1.0.*" />
<PackageReference Include="Microsoft.Azure.WebJobs.Extensions.SignalRService" Version="1.0.0" />
</ItemGroup>
</Project>
我能够使用以下Azure Function通过Azure SignalR Service发布消息。当 CosmosDB 集合中存在任何 AddOrUpdate() 操作时,将触发函数,并在中心以名称"fruitUpdate"发送信号。
#r "Microsoft.Azure.DocumentDB.Core"
#r "Microsoft.Azure.WebJobs.Extensions.SignalRService"
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using Microsoft.Azure.Documents;
using Microsoft.Azure.WebJobs.Extensions.SignalRService;
public static void Run(IReadOnlyList<Document> input, ILogger log, ICollector<SignalRMessage> signalRMessages)
{
if (input != null && input.Count > 0)
{
log.LogInformation("Documents modified " + input.Count);
foreach (var fruit in input)
{
signalRMessages.Add(
new SignalRMessage
{
Target = "fruitUpdated",
Arguments = new [] { fruit }
});
}
}
}
但是协商功能现在似乎不起作用。它会在没有任何线索的情况下抛出 500 个错误代码。以下是示例,
运行.csx
#r "Newtonsoft.Json"
using System;
using System.Net;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Primitives;
using Newtonsoft.Json;
public static IActionResult Run(HttpRequest req, ILogger log, object connectionInfo)
{
return (ActionResult)new OkObjectResult(connectionInfo);
}
函数.json
{
"bindings": [
{
"authLevel": "anonymous",
"name": "req",
"type": "httpTrigger",
"direction": "in",
"methods": [
"get",
"post"
]
},
{
"type": "signalRConnectionInfo",
"name": "connectionInfo",
"hubName": "flights",
"direction": "in",
"connectionStringSetting": "AzureSignalRConnectionString"
}
]
}
我尝试了所有组合。在某些情况下,Azure 文档很烦人!无输入\输出架构 它应该是不受欢迎的。Azure 产品团队应该认真对待它
信号R版本彼此不兼容。如果我们在服务器和客户端中使用不同版本的 SignalR dll,它们只是被动地关闭消息而不会引发错误。
我想我需要connectionInfo对象的JSON有效负载。你能在这里帮助我吗?
我在Serverless360上找到了答案。原来是类型问题和方法参数修饰。在参考信号服务库和装饰器后,它开始工作。在我看来,object
是一个基本类型,它应该已经接收或注入了连接信息。
#r "Newtonsoft.Json"
#r "Microsoft.Azure.WebJobs.Extensions.SignalRService"
using System;
using System.Net;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Primitives;
using Newtonsoft.Json;
using Microsoft.Azure.WebJobs.Extensions.SignalRService;
public static IActionResult Run(HttpRequest req, ILogger log, [SignalRConnectionInfo(HubName = "flights")]SignalRConnectionInfo connectionInfo)
{
return (ActionResult)new OkObjectResult(connectionInfo);
}
现在,协商函数按预期工作。希望对有类似问题的人有所帮助!
协商函数的示例输出有效负载
{"url":"https://myazuresignalrservice.service.signalr.net/client/?hub=myhubname","accessToken":"mybeareraccesstoken"}
更新
问题在于方法签名中*[SignalRConnectionInfo(HubName = "fruits")]SignalRConnectionInfo*
,而不是使用。
public static IActionResult Run(HttpRequest req, ILogger log, [SignalRConnectionInfo(HubName = "fruits")]SignalRConnectionInfo connectionInfo) { }
还发布了预期的有效载荷供您参考。如果您有任何疑问,请在评论中告诉我。