示例json:
{
"status": "ok",
"data": [{
"id": 1,
"name": "zhangsan"
},
{
"id": 2,
"name": "wangwu"
}
]
}
1 直接格式化打印
at ./test.json | jq .
{
"status": "ok",
"data": [
{
"id": 1,[......]
json配置为
{
"items": [
{
"url": "https://xxx.com",
"name": "xxx"
}
]
}
对应解析为
import "encoding/json"
type CfgItem struct {
Url string
Name string
Check bool
}
type Cfg struct[......]
func weworkAlarm(text string, mentionAll bool) {
mentionAllStr := ""
if mentionAll {
mentionAllStr = "@all"
}
dataJsonStr := fmt.Sprintf(`{"msgtype": "text", "text": {"content": "%s", "mentioned_list": [%s]}}`, text, mentionAllStr)[......]
本文参考了：http://pkghosh.wordpress.com/2012/05/06/hive-plays-well-with-json/
表示感谢！
总体来说，有两大类方法：
1、将json以字符串的方式整个入Hive表，然后使用LATERAL VIEW json_tuple的方法，获取所需要的列名。
2、将json拆成各个字段，入Hive表。这将需要使用第三方的SerDe，例如：https://code.google.com/p/hive-json-serde/[......]