ESQL 中的动态 JSON key/value 对生成

Question

如何将从外部系统检索到的 JSON 响应转换为 ESQL 中有意义的数据（key/value 对）？

检索到 JSON:

{
    "data": [
        {
            "name": "application.info.header",
            "value": "headerValue"
        },
        {
            "name": "entity.statistics.name.fullName",
            "value": "fullNameValue"
        },
        {
            "name": "application.info.matter",
            "value": "matterValue"
        },
        {
            "name": "entity.statistics.skill",
            "value": "skillValue"
        }
    ]
}

其中，

name ~ JSON 的层次结构（最后一个属性是键）
value ~ 键的值

预期 JSON:

{
    "data": {
        "application": {
            "info": {
                "header": "headerValue",
                "matter": "matterValue"
            }
        },
        "entity": {
            "statistics": {
                "name": {
                    "fullName": "fullNameValue"
                },
                "skill": "skillValue"
            }
        }
    }
}

不用说，这可以通过 Split 方法在 Java 中轻松实现 - 我正在 ESQL 中寻找合适的 method。

当前 ESQL 模块：

CREATE COMPUTE MODULE getDetails_prepareResponse
    CREATE FUNCTION Main() RETURNS BOOLEAN
    BEGIN
        DECLARE data REFERENCE TO InputRoot.JSON.Data.data.Item[1];
        SET OutputRoot.JSON.Data = InputRoot.JSON.Data;
        SET OutputRoot.JSON.Data.data = NULL;

        WHILE LASTMOVE(data) DO
            DECLARE keyA CHARACTER SUBSTRING(data.name BEFORE '.');
            DECLARE name CHARACTER SUBSTRING(data.name AFTER '.');
            DECLARE keyB CHARACTER SUBSTRING(name BEFORE '.');
            DECLARE key CHARACTER SUBSTRING(name AFTER '.');
            CREATE LASTCHILD OF OutputRoot.JSON.Data.data.{EVAL('keyA')}.{EVAL('keyB')}
            NAME key VALUE data.value;
            MOVE data NEXTSIBLING;
        END WHILE;

        RETURN TRUE;
    END;
END MODULE;

目前这是通过 ESQL 中的 SUBSTRING 方法处理的（仅限 3 个级别），但现在 JSON 级别是动态的（不限制 key/value 对）根据要求.

Answer 1

您可以实现自己的程序来拆分字符串。以这个答案为例。

该方法将 Delim 上的 S 拆分为 Env (Environment.Split.Array[]) 中的数组，并在重新填充之前删除 Environment.Split。

ESQL 中的动态 JSON key/value 对生成

Dynamic JSON key/value pairs generation in ESQL

java

json

ibm-integration-bus

extended-sql