. 在Logstash的config目录下创建mysql-es.conf配置文件，Logstash会根据该配置文件从MySQL中读 取数据并同步到ES库中。
input { jdbc { jdbc_connection_string => "jdbc:mysql://localhost:3306/p2p_transaction_0? useUnicode=true&characterEncoding=utf-8&useSSL=false" jdbc_user => "root" jdbc_password => "123" jdbc_driver_library => "e:/mysql-connector-java-8.0.11.jar" jdbc_driver_class => "com.mysql.cj.jdbc.Driver" jdbc_paging_enabled => true jdbc_page_size => "50000" #时区设置 jdbc_default_timezone =>"Asia/Shanghai" #要执行的sql statement_filepath => "e:/wanxinp2p-project_0.sql" #每隔10秒执行
跟最后一次运行的时间做比较
