Spark SQL使用get

#Spark SQL使用get| 来源: 网络整理| 查看: 265

get_json_object(string json_string, string path)

说明：第一个参数填写json对象变量，第二个参数使用$表示json变量标识，然后用 . 或 [] 读取对象或数组；如果输入的json字符串无效，那么返回NULL。

举例：数据准备如下：

使用实例：

with data_table as (select "{ \"timestamp\": \"2021-03-23T06:45:11.460Z\", \"metadata\": { \"beat\": \"filebeat\", \"type\": \"doc\", \"version\": \"6.6.1\", \"topic\": \"gateway_track_log\" }, \"service_port\": \"1111\", \"service_name\": \"gateway\", \"service_ip\": [{\"ip_a\":\"100.100.89.09\"},{\"ip_b\":\"100.100.89.10\"}], \"center_name\": \"open\" }" as col) select get_json_object(col,'$.timestamp') as `timestamp`, get_json_object(col,'$.metadata.type') as metadata_type, get_json_object(col,'$.service_ip[0].ip_a') as service_ip_a from data_table;

结果如下：

【本文地址】

公司简介

联系我们