如何解决使用 CosmosDB 触发器从 Azure 函数发送 Azure SignalR 消息
我正在开发一个应用程序,它使用 CosmosDB 来存储数据,然后当有人更新数据时,我希望客户端得到更新。 为此,我决定使用 changeFeed,然后使用 Azure Functions 和 Azure SignalR。
我已经设置了 2 个函数。 协商功能(此功能有效并且客户端正确连接到 SignalR 服务器) 还有一个 OnDocumentsChanged 函数,我的问题是让函数在发生变化时实际发送消息。
[FunctionName("OnDocumentsChanged")]
public static async Task Run(
[CosmosDBTrigger(
databaseName: "NewOrder",collectionName: "NewOrder",CreateLeaseCollectionIfNotExists = true,ConnectionStringSetting = "myserver_DOCUMENTDB",LeaseCollectionName = "leases")]
IReadOnlyList<Document> updatednewOrder,[SignalR(ConnectionStringSetting = "AzureSignalRConnectionString",HubName = "NewOrder")] IAsyncCollector<SignalRMessage> signalRMessages,ILogger log)
{
if (updatednewOrder != null && updatednewOrder.Count > 0)
{
foreach (var Orders in updatednewOrder)
{
await signalRMessages.AddAsync(new SignalRMessage
{
Target = "NewOrderUpdated",Arguments = new[] { Orders.Id }
});
}
}
}
我可以看到它在对数据库进行更改时正确触发,但没有发送消息。
我想我错过了实际发送 SignalRMessages 的部分,我只是不确定如何实现。
谢谢。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。