【问题标题】:Stream Analytics: performing a JOIN on events and ref. data in JSON流分析:对事件和参考执行 JOIN。 JSON 格式的数据
【发布时间】:2016-06-15 08:58:09
【问题描述】:

我想在 Azure 流分析中对传入的 JSON 事件和 JSON 引用数据执行 JOIN 查询。

JSON 事件如下所示:

{"devicename":"12345","value":25}

JSON 参考数据(简化)如下所示:

{
"Id": "configuration",
"Sites": [{
    "Id": "b83939b5-6502-4140-b807-205162ac4939",
    "Name": "site1",
    "Location": {
        "Latitude": 5.000,
        "Longitude": 5.000
    },
    "Lines": [{
        "Id": "e707a451-948a-498e-80de-d61bc448a5ef",
        "Name": "line1",
        "Sections": [{
            "Id": "d17d762c-4291-4912-9dcf-72113c9f0b4b",
            "Name": "section1",
            "Sensors": [{
                "Id": "S1_PL1_LS1_M1_device_001",
                "Name": "sensor1",
                "ExpectedAVG": 55,
                "ExpectedMIN": 35,
                "ExpectedMAX": 75,
                "TypeOfSensor": "Humidity"
            }, {
                "Id": "S1_PL1_LS1_M1_device_002",
                "Name": "sensor2",
                "ExpectedAVG": 105,
                "ExpectedMIN": 90,
                "ExpectedMAX": 118,
                "TypeOfSensor": "Temperature"
            }]
        }]
    }]
}]
}

现在我想对传入的设备数据和参考数据执行 JOIN。

SELECT
    i.devicename as pk,
    i.value as rk,
    system.timestamp as time,
    r.Sites.Lines.Sections.Sensors.Temperature as Temperature,
    r.Sites.Lines.Sections.Sensors.Humidity as Humidity
INTO
    output
FROM 
    IoTHubStream i
INNER JOIN 
    Reference r ON r.Sites.Lines.Sections.Sensors.Id = i.devicename

现在该怎么做呢?问题是参考数据可以改变,我想动态处理。 我正在考虑使用 WHERE 语句,但我不知道这会是什么样子,非常欢迎一些建议/帮助。

提前致谢!

【问题讨论】:

    标签: json azure azure-stream-analytics


    【解决方案1】:

    您可以使用本页 https://msdn.microsoft.com/en-us/library/azure/mt298451.aspx 中描述的 GetArrayElements 访问数组元素

    如果您的数据更改导致无法使用 GetArrayElements,请分享有关其更改方式的详细信息。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2020-08-13
      • 1970-01-01
      • 1970-01-01
      • 2021-07-14
      • 1970-01-01
      • 2018-04-14
      • 1970-01-01
      相关资源
      最近更新 更多