U-SQL尝试从嵌套的JSON对象中提取int列表

// 引用必要的命名空间
REFERENCE ASSEMBLY [Newtonsoft.Json];

// 定义输入数据的格式
CREATE TABLE IF NOT EXISTS InputData (
    jsonColumn string
);

// 定义输出数据的格式
CREATE TABLE IF NOT EXISTS OutputData (
    intValue int
);

// 提取int列表的查询
@result =
    SELECT
        JsonFunctions.JsonTuple(jsonColumn)["intList"] AS intList
    FROM
        InputData;

// 将int列表展开为多行数据
@expanded =
    SELECT
        int.Parse(JsonFunctions.JsonTuple(intList)["Value"]) AS intValue
    FROM
        @result
        CROSS APPLY
            EXPLODE(intList) AS t(intList);

// 将结果写入输出表
INSERT INTO OutputData
    SELECT *
    FROM @expanded;