Elasticsearch集成03

logstash下载

创建mysql.conf

input{
    jdbc{
        # jdbc驱动包位置
        jdbc_driver_library => "D:\\logstash\\logstash-8.3.3\\mysql-connector-java-5.1.47.jar"
        # 要使用的驱动包类
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        # mysql数据库的连接信息
        jdbc_connection_string => "jdbc:mysql://{$ip}:3309/${db_name}"
        # mysql用户
        jdbc_user => "${user_name}"
        # mysql密码
        jdbc_password => "${password}"
        # 定时任务，多久执行一次查询，默认一分钟，如果想要没有延迟，可以使用 schedule => "* * * * * *"
        schedule => "* * * * *"
        # 清空上传的sql_last_value记录
        clean_run => true
        # 你要执行的语句
        statement => "select * from area_code"
    }
}

output {
    elasticsearch{
        # es host : port
        hosts => ["localhost:9200"]
        # 索引
        index => "areacode"
        # _id
        document_id => "%{id}"
    }
}

启动
logstash -f logstash.conf