? ?Elasticsearch一個分布式多用戶能力的全文搜索引擎，基于RESTful web接口。ElasticSearch也支持存儲，查詢，排序，分頁等數據庫的功能。

下面介紹下如何把數據導入Elasticsearch

第一種方法：手動導入

1、cat test.json

{"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

[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是否存在數據

[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

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對應。

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、配置腳本

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",?#簇名?詳見：/usr/local/elasticsearch/config/elasticsearch.yml "url":"jdbc:mysql://localhost:3306/test",??#mysql數據庫地址 "user":"test",??#mysql用戶名 "password":"1234",??#mysql密碼 "sql":"select?*,id?as?_id?from?workers_info", "elasticsearch"?:?{"host"?:?"192.168.10.49","port"?:?9300 }, "index"?:?"myindex",??#新的index "type"?:?"mytype"??#新的type } }'|?java?\-cp?"${lib}/*"?\-Dlog4j.configurationFile=${bin}/log4j2.xml?\org.xbib.tools.Runner?\org.xbib.tools.JDBCImporter

chmod + import.sh

sh import.sh

3、查看數據是否導入elasticsearch

[root@ELKServer?bin]#?curl?-XGET?'http://localhost:9200/myindex/mytype/_search?pretty' {"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"}}?]} }

轉載于:https://blog.51cto.com/irow10/1840034

總結

以上是生活随笔為你收集整理的elasticsearch导入数据的几种方法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。