[Logstash filter use http] #Logstash #Http

logstash-filter-http.conf

input {
    jdbc {
        jdbc_driver_library => "/Users/wangxc/Develop/maven/repo/mysql/mysql-connector-java/5.1.46/mysql-connector-java-5.1.46.jar"    
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        jdbc_connection_string => "jdbc:mysql://localhost:3308/test"
        jdbc_user => "root"
        jdbc_password => "123456"
        statement => "SELECT * FROM account"
    }
}
filter {
	mutate {
		add_field => {"username" => "%{name}"}
	}
	rest {
		request => {
	        url => "http://localhost:8081/log/show2"
	        method => "post"
	        body => { "id" => "%{username}" "name" => "%{password}" }
    	}
    	target => "weather"
    }
}
output {
    stdout {
        codec => rubydebug{}        
    }
}