1.安装与elasticsearch相同版本号的logstash
在logstash的bin目录下
打开控制台 输入 logstash -e "input { stdin { } } output { stdout { } }"
注意:双引号不能改成单引号否则可能会报
ERROR: Unknown command '{'

返回我们输入的结果则证明安装成功
2.配置数据库同步的模板
在logstash建立mysqletc文件夹在文件夹内建一个配置文件例如mysql.conf内容如下
input {
jdbc {
# mysql jdbc connection string to our backup databse
jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/tensquare_article?characterEncoding=UTF8"
# the user we wish to excute our statement as
jdbc_user => "root"
jdbc_password => "123456"
# the path to our downloaded jdbc driver
jdbc_driver_library => "D:\tensquare\logstash-6.5.1\logstash-6.5.1\mysqletc\mysql-connector-java-5.1.46.jar"
# the name of the driver class for mysql
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_paging_enabled => "true"
jdbc_page_size => "20"
#以下对应着要执行的sql的绝对路径。
#statement_filepath => ""
statement => "SELECT id,title,content,state FROM tb_article"
#定时字段 各字段含义(由左至右)分、时、天、月、年,全部为*默认含义为每分钟都更新(测试结果,不同的话请留言指出)
schedule => "* * * * *"
}
}
output {
elasticsearch {
#ESIP地址与端口
hosts => "127.0.0.1:9200"
#ES索引名称(自己定义的)
index => "tensquare_article"
#自增ID编号
document_id => "%{id}"
document_type => "article"
}
stdout {
#以JSON格式输出
codec => json_lines
}
}
然后将mysql数据库驱动放入此文件夹内
3.运行logstash
打开cmd进入logstash/bin目录下 logstash -f 配置文件的相对路径例如:
logstash -f ../mysqletc/mysql.conf

mysql里先插入两条试验数据

一分钟后看到控制台上打印出sql语句

elasticsearch-head成功显示出插入的数据
至此,数据同步成功。
网友评论