logstash-input-jdbc 同时同步多个表的情况
时间：2021-07-01 10:21:17
帮助过：42人阅读
=>
"jdbc:mysql://localhost:3306/crm?zeroDateTimeBehavior=convertToNull"
jdbc_user =>
"root"
jdbc_password =>
""
jdbc_driver_library =>
"D:/siyang/elasticsearch-5.2.2/logstash-5.2.2/mysql-connector-java-5.1.30.jar"
jdbc_driver_class =>
"com.mysql.jdbc.Driver"
jdbc_paging_enabled =>
"true"
jdbc_page_size =>
"50000"
statement_filepath =>
"filename.sql"
schedule =>
"* * * * *"
type =>
"jdbc_office"
}
jdbc {
jdbc_connection_string =>
"jdbc:mysql://localhost:3306/crm?zeroDateTimeBehavior=convertToNull"
jdbc_user =>
"root"
jdbc_password =>
""
jdbc_driver_library =>
"D:/siyang/elasticsearch-5.2.2/logstash-5.2.2/mysql-connector-java-5.1.30.jar"
jdbc_driver_class =>
"com.mysql.jdbc.Driver"
jdbc_paging_enabled =>
"true"
jdbc_page_size =>
"50000"
statement =>
"SELECT * from sys_user"
schedule =>
"* * * * *"
type =>
"jdbc_user"
}
}
output {
stdout {
codec =>
json_lines
}
if[type] ==
"jdbc_office"{
elasticsearch {
hosts =>
"localhost:9200"
index =>
"contacts4"
document_type =>
"office1"
document_id =>
"%{id}"
}
}
if[type] ==
"jdbc_user"{
elasticsearch {
hosts =>
"localhost:9200"
index =>
"contacts4"
document_type =>
"user1"
document_id =>
"%{id}"
}
}
}
注意事项，数据库里面的字段不要用type，如果有，as成其他的名字，不然的话，这里判断会有异常
logstash-input-jdbc 同时同步多个表的情况
标签：doc pass user pat nec log 注意事项 class rod
