У меня есть ряд событий, которые основаны на значениях от устройств. Они читаются с интервалами, например каждый час. События доставляются в концентратор событий, который используется в качестве входных данных для задания Stream Analytics (SA).
Я хочу агрегировать и вычислять среднее значение в SA. В настоящее время я собираю и группирую события в SA, используя идентификатор источника и другие свойства, чтобы создать правильные группы и средние значения. Проблема в том, что средние значения не верны. Я думаю, что события либо не завершены и / или не коррелированы правильно.
Использование TumblingWindow создаст несколько статических окон, основанных на времени, но события, которые мне нужно агрегировать, могут встретиться в двух или более окнах.
Использование SlidingWindow, как я понимаю, будет запускать вывод при определенных условиях и «оглядываться назад» в течение указанного интервала. Это правильно? Если это правильно, я могу прикрепить один и тот же идентификатор, например, JobId, к каждому событию, которое мне нужно агрегировать, и значение, указывающее, является ли это последним событием. Когда в SA поступает последнее событие, срабатывает SlidingWindow, и мы можем «оглянуться назад» на все события с одинаковым идентификатором. Это возможно?
Есть ли другие варианты в этом случае? По сути, мне нужно соотнести ряд событий на основе других характеристик, отличных от времени.
Надеюсь, вы мне поможете.