1.下载和elasticsearch 相同版本的logstash.

　　2.进行解压后,进入bin下,新建一个文件mysql.conf,并输入

input {

stdin{

}

}

output {

stdout{

}

}

3.cmd进入bin 下,输入logstash -f mysql.conf  启动后,输入　　http://127.0.0.1:9600/

4.ok;说明已经启动了

 

一个配置

input {

stdin {

}

#可以设置多个jdbc,也就是多个表的映射,type和下面的进行对应

jdbc {

# mysql 数据库链接,shop为数据库名

jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/cheng"

# 用户名和密码

jdbc_user => "root"

jdbc_password => "admin"

# 驱动

jdbc_driver_library => "./../lib/mysql-connector-java-5.1.38.jar"

# 驱动类名

jdbc_driver_class => "com.mysql.jdbc.Driver"

#是否分页查询

jdbc_paging_enabled => "true"

jdbc_page_size => "50000"

# 执行的sql 文件路径+名称

statement_filepath => "./mysql.sql"

# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新

schedule => "* * * * *"

# 索引类型

type => "content"

}

}

filter {

json {

source => "message"

remove_field => ["message"]

}

}

 

output {

#可以设置多个type,也就是多个表的映射

if[type] == "content"{

elasticsearch {

hosts => ["localhost:9200"]

#es索引名称

index => "cmscontent"

#自增ID编号

document_id => "%{id}"

}

stdout {

codec => json_lines

}

}

}