Last active
June 26, 2019 06:35
-
-
Save vector4wang/cb4e03c50487a61463bcbd89661ddd4b to your computer and use it in GitHub Desktop.
[logstash mysql2mysql] #Logstash #数据同步 #Mysql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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