У меня есть облачное приложение на основе IoT, развернутое в Azure.Я получаю сообщения в очереди ServiceBus от другого стороннего облачного сервера (который, в свою очередь, получает от устройства).
Я вызываю события всякий раз, когда сообщение поступает на служебную шину, и запускаю выполнение приложения функции, которое сохраняет сообщениев базу данных через вызов API.
Теперь я хочу реализовать механизм, с помощью которого я могу инициировать событие, если я не получаю N сообщений в течение 1 часа для определенного устройства.
Предполагая, что в моей БД может быть зарегистрировано 1 миллион устройств, я не могу перебрать все записи, используя задание, чтобы посмотреть, равен ли счетчик N за данный период времени в 1 час.
Какое наилучшее возможное решение доступно в Azure для проведения такого мероприятия, если нет приема пищи?