Elk in Windows Environment - logstash+mysql (4)

One 、JDBC

We need to download the corresponding JDBC connector.

Click here to download JDBC

decompression , take mysql-connector-java-8.0.18.jar Put it in logstash Of jars Directory

F:\ELK\ELK8.2.3\logstash-8.2.3\logstash-core\lib\jars

Two 、 Prepare the data

Click to download sample data

3、 ... and 、 To configure conf

stay bin Created in the same level directory mysql.conf

input {
    
	jdbc {
    
	# Link string 
       jdbc_connection_string => "jdbc:mysql://localhost:3306/elk_01?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai"
       # user 
       jdbc_user => "root"
       # password 
       jdbc_password => "123456"
       jdbc_validate_connection => true
       jdbc_driver_library => "F:/ELK/ELK8.2.3/logstash-8.2.3/logstash-core/lib/jars/mysql-connector-java-8.0.18.jar"
       jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
       parameters => {
     "Product_id" => "Product1" }
       statement => "SELECT * FROM SalesJan2009 WHERE Product = :Product_id"
    }    
}
 
filter {
    
	mutate {
    
	 	rename => {
    
        	"longitude" => "[location][lon]"
        	"latitude" => "[location][lat]"
    	}
    }
}

output {
    
	stdout {
    
	}
 
   	elasticsearch {
    
     	index => "sales"
     	hosts => "119.3.20.91:9200"
     	document_type => "_doc"
	} 
}

Four 、 function conf

logstash.bat -f mysql.conf