Logstash是一種開源數(shù)據(jù)處理引擎，可以將多種數(shù)據(jù)源中的數(shù)據(jù)收集、轉(zhuǎn)換和傳輸?shù)侥繕?biāo)位置。Mysql是一種流行的關(guān)系型數(shù)據(jù)庫，常用于存儲和查詢結(jié)構(gòu)化數(shù)據(jù)。本文將介紹Logstash與Mysql的集成。

首先，需要安裝Logstash和Mysql。安裝方法可以參考官方文檔。接下來，在Logstash的配置文件中添加Mysql作為輸出插件：

output {
jdbc {
jdbc_connection_string =>"jdbc:mysql://localhost:3306/mydb"
jdbc_user =>"myuser"
jdbc_password =>"mypassword"
jdbc_driver_library =>"/path/to/mysql-connector-java.jar"
jdbc_driver_class =>"com.mysql.jdbc.Driver"
statement =>"INSERT INTO mytable (column1, column2) VALUES (?, ?)"
}
}

上述配置將Logstash的輸出流數(shù)據(jù)插入到Mysql中的mytable表格中的column1和column2列中。

需要注意的是，為了使用Mysql作為Logstash的輸出插件，需要先安裝JDBC驅(qū)動程序。該驅(qū)動程序可從Mysql的官方網(wǎng)站上下載并安裝。

可以使用Logstash的過濾器來處理輸入數(shù)據(jù)。例如，如果輸入數(shù)據(jù)包含JSON格式的數(shù)據(jù)，則可以使用以下配置將其解析并將其插入到Mysql表格中：

input {
stdin {}
}
filter {
json {
source =>"message"
}
}
output {
jdbc {
jdbc_connection_string =>"jdbc:mysql://localhost:3306/mydb"
jdbc_user =>"myuser"
jdbc_password =>"mypassword"
jdbc_driver_library =>"/path/to/mysql-connector-java.jar"
jdbc_driver_class =>"com.mysql.jdbc.Driver"
statement =>"INSERT INTO mytable (column1, column2) VALUES (?, ?)"
}
}

上述配置將從標(biāo)準(zhǔn)輸入（stdin）中接收J(rèn)SON格式的輸入數(shù)據(jù)，并將其解析為Logstash事件。然后，使用jdbc插件將Logstash事件插入到Mysql表格中。

綜上所述，Logstash和Mysql的集成可以實現(xiàn)將多種數(shù)據(jù)源中的數(shù)據(jù)收集、轉(zhuǎn)換和傳輸?shù)組ysql中的表格中。