У меня есть концентратор событий и задание потоковой аналитики, отправляющее данные в Power BI. Мне было интересно, как лучше всего настроить концентратор событий / для отслеживания активов?
например, у меня есть несколько клиентов, отправляющих в концентратор событий -> задание потоковой аналитики, и я хочу иметь возможность определять, переходит ли клиент с определенным идентификатором в автономный режим?
Ваше здоровье!
Если список идентификаторов относительно статичен, вы можете использовать объединение справочных данных для вывода всех идентификаторов, которые отсутствуют в каждом временном окне.
Если вы хотите вывести идентификаторы из самого потока и хотите определить, когда идентификатор, который был активен в предыдущем окне, не активен в текущем окне, вы можете использовать соединение с потоком. Вот пример
with MissingAssets as
(
select
PreviousWindowSignal.signalTime,
PreviousWindowSignal.AssetId
from
AssetSignalStream PreviousWindowSignal Timestamp by signalTime
left outer join
AssetSignalStream CurrentWindowSignal Timestamp by signalTime
on
PreviousWindowSignal.AssetId = CurrentWindowSignal.AssetId
and datediff(second,PreviousWindowSignal,CurrentWindowSignal) between 1 and 300
where
CurrentWindowSignal.AssetId is null
)
select
AssetId,
max(signalTime) MostRecentSignalInWindow
from
MissingAssets
group by
AssetId,
TumblingWindow(ss,300)
