当我在我的数据库(MySQL)中插入新数据时,Logstash 不会动态添加它:下面你会看到logstash.conf(它是将 elasticsearch与 mysql 连接的文件)
input {
jdbc {
jdbc_connection_string => "jdbc:mysql://localhost:3306/blog" #Accès à la base de données
jdbc_user => "root"
jdbc_password => ""
jdbc_driver_library => "C:\Users\saidb\Downloads\mysql-connector-java-5.1.47\mysql-connector-java-5.1.47.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
schedule => "* * * * *"
statement => "SELECT * FROM blog_pro WHERE id > :sql_last_value"
use_column_value => true
tracking_column => "id"
}
}
output {
elasticsearch {
hosts => "localhost:9200"
index => "blog_pro"
document_type => "data"
}
}
Run Code Online (Sandbox Code Playgroud)
当我执行命令行时logstash -f logstash.conf --debug:
C:\logstash-6.5.4\bin>logstash -f …Run Code Online (Sandbox Code Playgroud)