input {

    stdin {

    }

    jdbc {

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

        jdbc_connection_string => "jdbc:mysql://localhost:3306/es?characterEncoding=utf8&useSSL=true&serverTimezone=GMT"

        # 用户名和密码

        jdbc_user => "root"

        jdbc_password => "root"

        # 驱动

        jdbc_driver_library =>

        "C:/Users/Administrator/.m2/repository/mysql/mysql-connector-java/8.0.13/mysql-connector-java-8.0.13.jar"

        # 驱动类名

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

        jdbc_paging_enabled => "true"

        jdbc_page_size => "50000"

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

        statement_filepath => "H:/software/java/logstash-6.2.2/config/test.sql"

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

        schedule => "* * * * *"

        # 设定ES索引类型

        type => "content"

    }

}

filter {

    json {

            source => "message"

            remove_field => ["message"]

    }

}

output {

    elasticsearch {

        hosts => ["localhost:9200"]

        #ES索引名称（自己定义的）

        index => "cmscontent"

        #自增ID编号

        document_id => "%{id}"

    }

    stdout {

        codec => json_lines

    }

}