时间戳

首页 > 解决方案 > Azure 流分析 - 仅当事件与前一个事件不同时才输出事件

azure - Azure 流分析 - 仅当事件与前一个事件不同时才输出事件

问题描述

我有一种特殊情况，当将 LAG 与数组 (json) 中的输入数据结合使用时，流分析不会发送输出事件。

这是来自数据记录器的输入数据：

20.04.2019 16:05:04> 设备：[WISE-4012_00D0C9E43D10]，数据：[{"PE": 1,"UID":"WISE-4012_00D0C9E43D10","TIM":"2019-04-20T16:04: 55+01:00","记录":[[0, 0, 1, 0],[0, 1, 1, 0],[0, 2, 1, 0],[0, 3, 1, 0 ]]}]

我在天蓝色流分析中使用此查询：

SELECT
    PE, UID, TIM,
    UDF.DI1(InputIoThub) As DI1
FROM
    [IoTHub]
WHERE
    LAG(DI1, 1) OVER (LIMIT DURATION(minute, 1)) <> DI1

根据此说明：https ://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-stream-analytics-query-patterns

看起来 LAG 无法处理 UDF。

我用以下内容替换了 UDF：

SELECT
   PE, UID, TIM,
   GetArrayElement(GetArrayElement(Record,0), 3) AS DI_1
INTO
   [toPowerBI]
FROM
   [IoTHub]
WHERE
   LAG(DI_1, 1) OVER (LIMIT DURATION(minute, 1)) <> DI_1

但它也不起作用。

如果没有 WHERE clouse，流会生成正确的输出，所以我尝试使用 HAVING 代替但没有成功。

非常感谢您的帮助！

标签： azureazure-stream-analytics

解决方案

我希望我的问题不会令人困惑，我正在寻找一种解决方案，仅在值发生变化时才从数据记录器发送数字输入 (DI_1)。因此，原因是在 PowerBI 中计算时间差。

与此同时，我找到了一个解决方案：

LAG 功能可以正常工作，也可以使用 WHERE

SELECT
   PE, UID, TIM,
   GetArrayElement(GetArrayElement(Record,0), 3) AS DI_1
INTO
   [toPowerBI]
FROM
   [IoTHub]
WHERE
   LAG(GetArrayElement(GetArrayElement(Record,0), 3), 1) 
   OVER (LIMIT DURATION(minute, 10)) <>    
   GetArrayElement(GetArrayElement(Record,0), 3)

推荐阅读