Skip to content

Instantly share code, notes, and snippets.

@vector4wang
Last active June 26, 2019 06:35
Show Gist options
  • Save vector4wang/cb4e03c50487a61463bcbd89661ddd4b to your computer and use it in GitHub Desktop.
Save vector4wang/cb4e03c50487a61463bcbd89661ddd4b to your computer and use it in GitHub Desktop.
[logstash mysql2mysql] #Logstash #数据同步 #Mysql
input {
jdbc {
jdbc_driver_library => "D:\repo\mysql\mysql-connector-java\5.1.40\mysql-connector-java-5.1.40.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://xxx:8840/data"
jdbc_user => "xxx"
jdbc_password => "xxx@ed"
statement => "SELECT * FROM xxx_t_job_function_net_bak20140828 WHERE id = :id"
parameters => { "id" => 3510 }
}
}
filter {
grok {
match => {"@timestamp" => "%{YEAR:year}-%{MONTHNUM:month}-%{MONTHDAY:day}" }
add_field => { "current_version" => "%{year}%{month}%{day}"}
}
jdbc_streaming {
# 加了会错误,可能引用了上面的input jdbc_driver_library => "D:\repo\mysql\mysql-connector-java\5.1.40\mysql-connector-java-5.1.40.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://192.16xxx64:3306/dict"
jdbc_user => "xxx"
jdbc_password => "xxx"
statement => "SELECT location_name_cn FROM dict_location WHERE location_code = :codeParam"
parameters => { "codeParam" => "code"}
target => "code"
}
if [code] and [code][0] and ("location_name_cn" in [code][0]) {
ruby {
code => "
r = ''
event.get('code').each do |variable|
r = r + variable['location_name_cn'] + ';'
end
event.set('code',r)
"
}
} else {
mutate {
replace => { "code" => ""}
}
}
}
output {
stdout {
codec => rubydebug{}
}
jdbc {
driver_jar_path => "D:\repo\mysql\mysql-connector-java\5.1.40\mysql-connector-java-5.1.40.jar"
driver_class => "com.mysql.jdbc.Driver"
connection_string => "jdbc:mysql://120.xxx840/testcase"
username => "xxxx"
password => "crawler9988xxxed"
statement => ["INSERT INTO job_function_20190621 ( code_val, name_val, level_val, source_name, version ) VALUES (?,?,?,?,?)","code","name","level","source_name","current_version"]
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment