这是一个JSON输入包示例。我正在编写转换查询以获取数据,它工作得很好。
[{
"source": "xda",
"data":
[{
"masterTag": "UNIFY",
"speed": 180
}],
"EventEnqueuedUtcTime": "2018-07-20T19:28:18.5230000Z",
},
{
"source": "xda",
"data": [{
"masterTag": "UNIFY",
"speed": 214
}],
"EventEnqueuedUtcTime": "2018-07-20T19:28:20.5550000Z",
}
]
但是,当消息对象以“profilter”的名称发送到物联网集线器时,已经向该消息对象添加了一个自定义属性。这不在有效负载内,但存在于消息对象中。我可以使用Azure函数获取此属性,但我不确定如何在流分析转换查询中获取它。我有办法拿到吗?
基本转换查询:
WITH data AS
(
SELECT
source,
GetArrayElement(data,0) as data_packet
FROM input
)
SELECT
source,
data_packet.masterTag
INTO
output
FROM data