azure - 如何使用流分析查询呈现 JSON

Question

我有 JSON 形式的输入存储在 Blob 存储中我有 SQL Azure 表形式的输出。

我编写了查询并成功将 JSON 中特定属性的值移动到 SQL Azure 表的相应列。

现在，对于一列，我想将整个 JSON 有效负载复制为一个 sql 列中的序列化字符串，但我没有获得适当的库函数来执行此操作。

SELECT
     CASE 
        WHEN GetArrayLength(E.event) > 0
            THEN GetRecordPropertyValue(GetArrayElement(E.event, 0), 'name')
        ELSE ''
    END AS EventName 
    ,E.internal.data.id as DataId
    ,E.internal.data.documentVersion as DocVersion

    ,E.context.custom As CustomDimensionsPayload

Into OutputTblEvents
FROM InputBlobEvents E

这个CustomDimensionsPayload实际上应该是一个JSON

Answer 1

我创建了一个用户定义的函数来为我完成这项工作:

function main(InputJSON) {
    var InputJSONString = JSON.stringify(InputJSON);
    return InputJSONString;
}

然后，在查询中，我使用了如下函数:

SELECT udf.ConvertToJSONString(COLLECT()) AS InputJSON
INTO outputX
FROM inputY