input {
jdbc {
#type => "b"
jdbc_connection_string => "jdbc:mysql://ip:3306/vw"
jdbc_user => "xxx"
jdbc_password => "xxxx"
jdbc_driver_library => "/opt/logstash6/mysql/mysql-connector-java-5.1.30-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_paging_enabled => "true"
jdbc_page_size => "150000"
use_column_value => true
tracking_column => locateTime
record_last_run => true
last_run_metadata_path => "/opt/logstash6/inputtxt/trackv/vw_z_history.txt"
statement => "select id
locateTime
from ${z_history_table} where locateTime > :sql_last_value and lng_w84 != '0.000000' AND lat_w84 != '0.000000' order by locateTime asc"
schedule => "* * * * *"
# schedule => "0 * * * *"
# 索引类型
codec=>json
}
}
在数据库中, locateTime 字段就是这样定义的, 其中 T 是大写,
提示:
tracking_column not found in dataset. {:tracking_column=>"locateTime"}
如果将 tracking_column => locatetime 即将 T换成小写 t
不会报错, 追踪文件中的 时间没有修改, 如果默认空文件, 里面一直是空的。 如果给了一个 默认时间, 启动的时候 sql语句也从文件中读取该时间的值, 但是不更新。
jdbc {
#type => "b"
jdbc_connection_string => "jdbc:mysql://ip:3306/vw"
jdbc_user => "xxx"
jdbc_password => "xxxx"
jdbc_driver_library => "/opt/logstash6/mysql/mysql-connector-java-5.1.30-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_paging_enabled => "true"
jdbc_page_size => "150000"
use_column_value => true
tracking_column => locateTime
record_last_run => true
last_run_metadata_path => "/opt/logstash6/inputtxt/trackv/vw_z_history.txt"
statement => "select id
locateTime
from ${z_history_table} where locateTime > :sql_last_value and lng_w84 != '0.000000' AND lat_w84 != '0.000000' order by locateTime asc"
schedule => "* * * * *"
# schedule => "0 * * * *"
# 索引类型
codec=>json
}
}
在数据库中, locateTime 字段就是这样定义的, 其中 T 是大写,
提示:
tracking_column not found in dataset. {:tracking_column=>"locateTime"}
如果将 tracking_column => locatetime 即将 T换成小写 t
不会报错, 追踪文件中的 时间没有修改, 如果默认空文件, 里面一直是空的。 如果给了一个 默认时间, 启动的时候 sql语句也从文件中读取该时间的值, 但是不更新。
1 个回复
suhzh
赞同来自: