Elasticsearch一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。ElasticSearch也支持存储，查询，排序，分页等数据库的功能。
下面介绍下如何把数据导入Elasticsearch
第一种方法：手动导入
1、cat test.json
|
1
2
|
{"index":{"_index":"stuff_orders","_type":"order_list","_id":903713}}
{"real_name":"刘备","user_id":48430,"address_province":"上海","address_city":"浦东新区","address_district":null,"address_street":"上海市浦东新区广兰路1弄2号345室","price":30.0,"carriage":6.0,"state":"canceled","created_at":"2013-10-24T09:09:28.000Z","payed_at":null,"goods":["营养早餐：火腿麦满分"],"position":[121.53,31.22],"weight":70.0,"height":172.0,"sex_type":"female","birthday":"1988-01-01"}
|
2、导入elasticsearch
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
[root@ELKServer opt]# curl -XPOST 'localhost:9200/stuff_orders/_bulk?pretty' --data-binary @test.json
{
"took" : 600,
"errors" : false,
"items" : [ {
"index" : {
"_index" : "stuff_orders",
"_type" : "order_list",
"_id" : "903713",
"_version" : 1,
"_shards" : {
"total" : 2,
"successful" : 1,
"failed" : 0
},
"status" : 201
}
} ]
}
|
3、查看elasticsearch是否存在数据
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
[root@ELKServer opt]# curl localhost:9200/stuff_orders/order_list/903713?pretty
{
"_index" : "stuff_orders",
"_type" : "order_list",
"_id" : "903713",
"_version" : 1,
"found" : true,
"_source" : {
"real_name" : "刘备",
"user_id" : 48430,
"address_province" : "上海",
"address_city" : "浦东新区",
"address_district" : null,
"address_street" : "上海市浦东新区广兰路1弄2号345室",
"price" : 30.0,
"carriage" : 6.0,
"state" : "canceled",
"created_at" : "2013-10-24T09:09:28.000Z",
"payed_at" : null,
"goods" : [ "营养早餐：火腿麦满分" ],
"position" : [ 121.53, 31.22 ],
"weight" : 70.0,
"height" : 172.0,
"sex_type" : "female",
"birthday" : "1988-01-01"
}
}
|
第二种方法：从数据库中导入
参考：http://blog.csdn.net/laoyang360/article/details/51694519
1、下载安装插件elasticsearch-jdbc-2.3.4.0
|
1
|
weget http:
//xbib
.org
/repository/org/xbib/elasticsearch/importer/elasticsearch-jdbc/2
.3.4.0
/elasticsearch-jdbc-2
.3.4.0-dist.zip
|
elasticsearch-jdbc-2.3.4.0-dist.zip的版本要和你安装的elasticsearch对应。
|
1
2
3
|
unzip elasticsearch-jdbc-2.3.4.0-dist.zip
mv
elasticsearch-jdbc-2.3.4.0
/usr/local/
cd
/usr/local/elasticsearch-jdbc-2
.3.4.0/
|
2、配置脚本
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
vim
import
.sh
#!/bin/sh
JDBC_IMPORTER_HOME=
/usr/local/elasticsearch-jdbc-2
.3.4.0
bin=$JDBC_IMPORTER_HOME
/bin
lib=$JDBC_IMPORTER_HOME
/lib
echo
'{
"type"
:
"jdbc"
,
"jdbc"
: {
"elasticsearch.autodiscover"
:
true
,
"elasticsearch.cluster"
:
"my-application"
,
"url"
:
"jdbc:mysql://localhost:3306/test"
,
"user"
:
"test"
,
"password"
:
"1234"
,
"sql"
:
"select *,id as _id from workers_info"
,
"elasticsearch"
: {
"host"
:
"192.168.10.49"
,
"port"
: 9300
},
"index"
:
"myindex"
,
"type"
:
"mytype"
}
}'| java \
-
cp
"${lib}/*"
\
-Dlog4j.configurationFile=${bin}
/log4j2
.xml \
org.xbib.tools.Runner \
org.xbib.tools.JDBCImporter
|
chmod + import.sh
sh import.sh
3、查看数据是否导入elasticsearch
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
[root@ELKServer bin]
{
"took"
: 15,
"timed_out"
:
false
,
"_shards"
: {
"total"
: 5,
"successful"
: 5,
"failed"
: 0
},
"hits"
: {
"total"
: 1,
"max_score"
: 1.0,
"hits"
: [ {
"_index"
:
"myindex"
,
"_type"
:
"mytype"
,
"_id"
:
"AVZyXCReGHjmX33dpJi3"
,
"_score"
: 1.0,
"_source"
: {
"id"
: 1,
"workername"
:
"xing"
,
"salary"
: 10000,
"tel"
:
"1598232123"
,
"mailbox"
:
"xing@qq.com"
,
"department"
:
"yanfa"
,
"sex"
:
"F"
,
"qq"
: 736019646,
"EmployedDates"
:
"2012-12-21T00:00:00.000+08:00"
}
} ]
}
}
|
![wKioL1e1dCCB5tn7AABBoLN-zp4909.png]( "O09`AQ8817J9~0ULMF35L@Y.png")
本文转自 irow10 51CTO博客，原文链接：http://blog.51cto.com/irow10/1840034，如需转载请自行联系原作者
