Hive解析Json数组超全讲解（一）

在Hive中会有很多数据是用Json格式来存储的，如开发人员对APP上的页面进行埋点时，会将多个字段存放在一个json数组中，因此数据平台调用数据时，要对埋点数据进行解析。接下来就聊聊Hive中是如何解析json数据的。

Hive自带的json解析函数

1. get_json_object

• 语法：get_json_object(json_string, '$.key')

• 说明：解析json的字符串json_string,返回path指定的内容。如果输入的json字符串无效，那么返回NULL。这个函数每次只能返回一个数据项。

• 示例：

select 
get_json_object('{"name":"zhangsan","age":18}','$.name');

• 结果：

如果既要解析name字段，也解析age字段，则可以这样写：

select 
get_json_object('{"name":"zhangsan","age":18}','$.name'),
get_json_object('{"name":"zhangsan","age":18}','$.age');

但是如果要解析的字段有很多，再这样写就太麻烦了，所以就有了 json_tuple 这个函数。

2. json_tuple

• 语法： json_tuple(json_string, k1, k2 ...)
  

• 说明：解析json的字符串json_string,可指定多个json数据中的key，返回对应的value。如果输入的json字符串无效，那么返回NULL。
  

• 示例：

select 
b.name
,b.age
from tableName a lateral view
json_tuple('{"name":"zhangsan","age":18}','name','age') b as name,age;

• 结果:

注意：上面的json_tuple函数中没有$.

如果在使用json_tuple函数时加上$.就会解析失败：

select 
b.name
,b.age
from tableName a lateral view
json_tuple('{"name":"zhangsan","age":18}','$.name','$.age') b as name,age;

结果:

字段全是NULL，所以json_tuple函数不需要加$.了，否则会解析不到。

总结：json_tuple相当于get_json_object的优势就是一次可以解析多个json字段。但是如果我们有个json数组，这两个函数都无法处理。

Hive解析json数组

一、嵌套子查询解析json数组

如果有一个hive表，表中 json_str 字段的内容如下：

我们想把这个字段解析出来，形成如下的结构：

要解析这个json数组，仅用上面介绍的两个函数就解析不出来了，还需用到如下介绍的几个函数：

explode函数

• 语法： explode(Array OR Map)
  

• 说明：explode()函数接收一个array或者map类型的数据作为输入，然后将array或map里面的元素按照每行的形式输出，即将hive一列中复杂的array或者map结构拆分成多行显示，也被称为列转行函数。
  

• 示例：
  

-- 解析array
hive> select explode(array('A','B','C'));
OK
A
B
C
-- 解析map
hive> select explode(map('A',10,'B',20,'C',30));
OK
A       10
B       20
C       30

regexp_replace函数

• 语法: regexp_replace(string A, string B, string C)
  

• 说明：将字符串A中的符合java正则表达式B的部分替换为C。注意，在有些情况下要使用转义字符，类似oracle中的regexp_replace函数。
  

• 示例：
  

hive> select regexp_replace('foobar', 'oo|ar', ''); 
OK
fb

上述示例将字符串中的 oo 或 ar 替换为''。

有了上述几个函数，接下来我们来解析json_str字段的内容：

1. 先将json数组中的元素解析出来，转化为每行显示：

hive> SELECT explode(split(regexp_replace(regexp_replace('[{"website":"baidu.com","name":"百度"},{"website":"google.com","name":"谷歌"}]', '\\[|\\]',''),'\\}\\,\\{','\\}\\;\\{'),'\\;'));
OK
{"website":"baidu.com","name":"百度"}
{"website":"google.com","name":"谷歌"}

对上述sql进行简要说明：

SELECT explode(split(
    regexp_replace(
        regexp_replace(
            '[
                {"website":"baidu.com","name":"百度"},
                {"website":"google.com","name":"谷歌"}
            ]', 
            '\\[|\\]' , ''), 将json数组两边的中括号去掉
              '\\}\\,\\{' , '\\}\\;\\{'), 将json数组元素之间的逗号换成分号
                 '\\;') 以分号作为分隔符(split函数以分号作为分隔)
          );

为什么要将json数组元素之间的逗号换成分号？

因为元素内的分隔也是逗号，如果不将元素之间的逗号换掉的话，后面用split函数分隔时也会把元素内的数据给分隔，这不是我们想要的结果。

       b.上步已经把一个json数组转化为多个json字符串了，接下来结合son_tuple函数来解析json里面的字段：

select 
json_tuple(explode(split(
regexp_replace(regexp_replace('[{"website":"baidu.com","name":"百度"},{"website":"google.com","name":"谷歌"}]', '\\[|\\]',''),'\\}\\,\\{','\\}\\;\\{'),'\\;')) 
, 'website', 'name') ;

执行上述语句，结果报错了：

FAILED: SemanticException [Error 10081]: UDTF's are not supported outside the SELECT clause, nor nested in expressions

意思是UDTF函数不能写在别的函数内，也就是这里的explode函数不能写在json_tuple里面。

既然explode函数不能写在别的json_tuple里面，那我们可以用子查询方式，如下所示：

select json_tuple(json, 'website', 'name') 
from (
select explode(split(regexp_replace(regexp_replace('[{"website":"baidu.com","name":"百度"},{"website":"google.com","name":"谷歌"}]', '\\[|\\]',''),'\\}\\,\\{','\\}\\;\\{'),'\\;')) 
as json) t;

执行上述语句，没有报错，执行结果如下：

www.baidu.com   百度
google.com      谷歌

二 使用 lateral view 解析json数组

hive表中 goods_id 和 json_str 字段的内容如下：

目的：把 goods_id 字段和 json_str 字段中的monthSales解析出来。