jsonpaths不支持含.的json key解析 #17545

U_1676450440405_8311 · 2023年02月15日 08:52

我们生产环境中json字符串的key是包含. 的
json example:

{
     "ts":1662565608.72016,
     "uid":"CKqtT7etgpCZDB5x9",
     "id.orig_h":"10.1.3.168",
     "id.orig_p": 49528
}

尝试过以下几种方式解析id.orig_h和id.orig_p的值，结果都是null

"jsonpaths" = "[\"$['ts']",\"$['uid']\",\"$['id.orig_h']\",\"$['id.orig_p']\"]"
"jsonpaths" = "[\"$.ts\",\"$.uid\",\"$.id\.orig_h\",\"$.id\.orig_p\"]"

预想是从kafka消费数据，通过stream load的方式能低成本直接导入starrocks，但目前jsonpaths 无法解析json key中包含. 的键值对。
于是目前放弃了本方案，只能通过flink sql insert into srtale select from kafkatable 的方式导入，建议后续功能能补充对jsonpath 的解析语法

目前该需求已经提交issus到github