服务总线或队列处理

Service Bus or Queue Processing

可能是个愚蠢的问题。

一般来说,让程序侦听 MQTT 源(已完成)、将消息放入队列或服务总线然后通过 Azure 自动处理这些消息的最佳方法是什么?

我将如何处理队列中的消息?有没有办法让某些 Azure function/feature 在经过一些操作后自动将其放入存储帐户和数据库中?通常最好的方法是什么?最好使用 C#。

  1. 供稿侦听数据供稿(完成)
  2. 将消息放入队列或服务总线(轻松完成)
  3. Azure 上的某些东西会获取该项目并将其放在存储帐户和 Cosmos 数据库中。 (停留在最佳方法上)

谢谢。

您只需添加一条消息,而不是服务总线队列或存储帐户队列。两者都为作为消费者的 Azure Functions 提供绑定。同样使用 Azure 函数,您可以使用输出绑定并保存到存储帐户 (blob) 或 Cosmos DB。

以下是有用的链接:

https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-cosmosdb?tabs=csharp

https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-storage-blob

https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus