小编Saï*_*adj的帖子

Logstash 异常 预期第 1 行第 1 列的 #、输入、过滤器、输出之一

当我在我的数据库(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)

mysql sql jdbc elasticsearch logstash

1
推荐指数
1
解决办法
3243
查看次数

标签 统计

elasticsearch ×1

jdbc ×1

logstash ×1

mysql ×1

sql ×1