有点耗内存
下载logstash7.7.1 ,直接下载zip的包就可以,里面包括linux和win的一起
配置方法—配置文件内容可以见下文中附录
# file: bin/jdbcconf/mysqlsyn.confinput { jdbc { # jdbc驱动包位置 jdbc_driver_library => "D:\green_soft\logstash-7.7.1\mysql-connector-java-5.1.46/mysql-connector-java-5.1.46-bin.jar" # 要使用的驱动包类,有过java开发经验的应该很熟悉这个了,不同的数据库调用的类不一样。 jdbc_driver_class => "com.mysql.jdbc.Driver" # myqsl数据库的连接信息 jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/es_test" # mysql用户 jdbc_user => "root" # mysql密码 jdbc_password => "root" # 定时任务, 多久执行一次查询, 默认一分钟,如果想要没有延迟,可以使用 schedule => "* * * * * *" schedule => "* * * * *" # 你要执行的语句 statement => "select * from articles where id > :sql_last_value" type => "_doc" record_last_run => true use_column_value => true tracking_column => "id" # tracking_column_type => "timestamp" }}output { # 将数据输出到ElasticSearch中 elasticsearch { # es ip加端口 hosts => ["127.0.0.1:9200"] # es文档索引 index => "es_test" # 指定存储的类型 document_type => "_doc" # 建立索引 # action => "index" # es文档数据的id,%{id}代表的是用数据库里面记录的id作为文档的id document_id => "%{id}" }}