logstash中的sql_last_value始终为351

Question

我正在使用logstash将索引插入到elasticsearch。我的conf看起来像这样：

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://localhost:3306/sample"
        jdbc_user => "root"
        jdbc_password => ""
        jdbc_driver_library => "/usr/share/logstash/logstash-core/lib/jars/mysql-connector-java-5.1.48.jar"
        jdbc_driver_class => " com.mysql.jdbc.Driver"
        tracking_column => "time"
        use_column_value => true
        statement => "SELECT time, firstname, lastname, email FROM sample.sample where time > :sql_last_value;"
        schedule => " * * * * * *"
}
}
output {
    elasticsearch {
document_id=> "%{time}"
    document_type => "doc"
        "hosts" => ["myhost"]
        "index" => "sample" 
    }
stdout{
  codec => rubydebug
  }
}

当我使用logstash执行这个文件时，我得到了查询：

SELECT time, firstname, lastname, email FROM sample.sample where time > 351

但是在我正在跟踪的MySQL数据库中，time列是currenttimestamp，我认为sql_last_value包含了这个字段的值。我是否做了与sql_last_value相关的错误操作

Answer 1

我做错了什么:如果tracking_column不是int类型，我们需要指定tracking_column_type。在我的例子中，tracking_column的类型是timestamp。因此，我需要添加以下内容：

tracking_column_type =>"timestamp"

这解决了我的问题。