Шина обслуживания или обработка очереди

Question

Вероятно, глупый вопрос.

В общем, каков наилучший подход, чтобы программа прослушивала канал MQTT (выполнено), помещала сообщения в очередь или служебную шину, а затем обрабатывала их автоматически с помощью Azure?

Как мне обрабатывать сообщения в очереди? Есть ли способ для какой-нибудь функции / функции Azure автоматически поместить ее в учетную запись хранения и базу данных после некоторой манипуляции? Вообще какой подход лучше? В идеале, используя C#.

1. Канал прослушивает каналы данных (готово)
2. Помещает сообщение в очередь или служебную шину (легко сделать)
3. Что-то на Azure возьмет этот предмет и поместит его в учетную запись хранения и базу данных Cosmos. (застрял в лучшем подходе)

Спасибо.

Answer 1

Вам просто нужно добавить сообщение без очереди служебной шины или очереди учетной записи хранения. Оба предоставляют привязки для Azure функций, которые будут потребителями. Также используя функции Azure, вы можете использовать выходные привязки и сохранять их в учетной записи хранения (BLOB) или в базе данных Cosmos.

Вот полезные ссылки:

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