logstash-jdbc-input与mysql数据库同步

大多数情况下我们的数据都存放在了数据库中，但是elasticsearch它有自己的索引库，那么如果我们在做搜索的是时候就需要将数据库中的数据同步到elasticsearch中，在这里我们使用logstash的logstash-jdbc-input的插件进行与数据库的同步，对于logstash与数据库同步，我们可以设置elasticsearch与数据库同步的时间，使用这种方式进行同步还是很方便的。

1、下载并安装logstash

注意下载的版本要和你的elasticsearch的版本号一致，我的版本elasticsearch6.2.2

logstash下载地址：https://www.elastic.co/downloads/logstash

下载后之后，直接解压就好

(elasticsearch的环境搭建可参考http://www.cnblogs.com/xuwenjin/p/8745624.html)

2、配置logstash

对于logstash5.x以上版本，它自身已经集成了这个插件，不需要我们去单独安装，直接使用即可。我这里说一下与mysql进行同步的简单配置

在logstash文件目录下，新建一个文件夹(命名随意)。如：mysql

2.1 先把一个jdbc驱动放到这个文件夹下，用来连接mysql数据库

　使用maven项目的，可在pom文件中，加入以下依赖，然后将jar包拷贝出来就行

　<dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.40</version>
  </dependency>

更多相关文章

随机推荐