Elasticsearch同步MySQL

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《Elasticsearch同步MySQL》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

• 花了一个晚上+一个上午，终于将MySQL中的数据同步到

  Elasticsearch

  ，做个简单的记录。

• 整个过程需要用到MySQL的

  river

  插件，

  GitHub

  上有

  installation

  可以参考。

• 虽然最后的配置过程很简单，但我在配置的过程中遇到了不少的问题，可能是因为

  ES

  版本的原因吧。可以参考...

• 环境：

  Ubuntu

  +

  JDK7

配置过程如下：

step 1.

下载

ES

elasticsearch-1.1.0

${ES_HOME}

step 2.

进入

${ES_HOME}

cd  ${ES_HOME}

安装

river

bin/plugin --install river-jdbc --url http://bit.ly/1jyXrR9

下载

mysql-connector-java-5.1.30-bin.jar

${ES_HOME}/lib

step 3.

创建一个

JDBC river

curl -XPUT 'localhost:9200/_river/my_jdbc_river/_meta' -d '{
     "type" : "jdbc",
     "jdbc" : {
         "driver" : "com.mysql.jdbc.Driver",
         "url" : "jdbc:mysql://localhost:3306/profile",
         "user" : "",
         "password" : "",
         "sql" : "select * from profile.user",
         "index" : "profile",
         "type" : "user"
     }
 }'

其中

profile

scheme

user

table

step 4.

测试导入效果

curl -XGET 'localhost:9200/profile/user/_search?pretty&q=*'

理论要掌握，实操不能落！以上关于《Elasticsearch同步MySQL》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！