7.1 下载数据
[root@kibana ~]# lftp 192.168.0.254
lftp 192.168.0.254:~> get /pub/elk/accounts.json
lftp 192.168.0.254:/pub/elk> get shakespeare.json.gz
lftp 192.168.0.254:/pub/ansible_soft> get logs.jsonl.gz
7.2 解压数据
[root@kibana ~]# gzip -d logs.jsonl.gz
[root@kibana ~]# gzip -d shakespeare.json.gz
[root@kibana ~]# gzip -d accounts.json.gz
[root@kibana ~]# ll -h *.json*
-rw-r--r-- 1 root root 240K 8月 18 18:09 accounts.json
-rw-r--r-- 1 root root 51M 8月 13 16:48 logs.jsonl
-rw-r--r-- 1 root root 25M 8月 13 16:48 shakespeare.json
7.3 数据格式的讲解
[root@kibana ~]# vim shakespeare.json
1 {"index":{"_index":"shakespeare","_type":"act","_id":0}}
注:_index:索引(数据库名)、_type:类型(表)、_id:行
2 {"line_id":1,"play_name":"Henry IV","speech_number":"","line_number":"","speaker":"","text_entry":"ACT I"}
注:具体数据
[root@kibana ~]# sed -n ‘1,100p‘ shakespeare.json #答应文件shakespeare.json 的1-100行
[root@kibana ~]# sed -n ‘1,100p‘ shakespeare.json | sed -n ‘1~2p‘ 打印奇数行【奇数行都是索引、类型、ID】
{"index":{"_index":"shakespeare","_type":"act","_id":0}}
{"index":{"_index":"shakespeare","_type":"scene","_id":1}}
{"index":{"_index":"shakespeare","_type":"line","_id":2}}
7.1 使用_bulk 批量导入数据
–批量导入数据使用POST 方式,数据格式为json,url编码使用data-binary
–导入含有index 配置的json文件
[root@kibana ~]# curl -XPOST http://192.168.0.10:9200/_bulk --data-binary @shakespeare.json
[root@kibana ~]# curl -XPOST http://192.168.0.10:9200/_bulk --data-binary @logs.jsonl
–导入没有有index 配置的json文件
[root@kibana ~]# curl -XPOST http://192.168.0.10:9200/00/xx/_bulk --data-binary @accounts.json #00表示索引,xx表示类似
导入完成后打开浏览器(打开我们的head插件)
http://192.168.0.10:9200/_plugin/head/
这个时候就可以发现我们创建的索引了