现在的情况:
来自IoT-hub的数据在Stream Analytics中处理并直接发送到PowerBI .
Tihs是Stream Analytics中的查询:
SELECT PE,UID,TIM,UDF.DI1(InputIoThub)作为DI1 INTO [PowerBI] FROM [IotHub]
此查询到目前为止工作正常 . 现在我想在PowerBI中进行一些计算,因此只有当它与前一个输出事件不同时才需要发送输出事件 .
以下是使用LAG函数解决该问题的描述,但我不知道如何正确实现它:
SELECT Make,Time FROM输入TIMESTAMP BY时间WHERE LAG(Make,1)OVER(LIMIT DURATION(分钟,1))<> Make
非常感谢您的帮助!
1 回答
请查看“确定值是否已更改”的查询模式
https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-stream-analytics-query-patterns
谢谢