logstash 7.X系列之：logstash采集mysql数据并输出到csv文件

input {                                            
 jdbc {                                            
    codec => plain { charset => "UTF-8"}                                            
    jdbc_driver_library => "/home/mysql/mysql-connector-java-8.0.22.jar"                                            
    jdbc_driver_class => "com.mysql.jdbc.Driver"                                            
    jdbc_connection_string => "jdbc:mysql://192.168.0.144:3306/jingneng?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToN                                            
    ull&useSSL=true&serverTimezone=GMT%2B8"                                            
    jdbc_user => "jingneng"                                            
    jdbc_password => "2HjdZNTwGt2Wfx86"                                            
           #查询品牌类目                                            
            statement =>"select id,names from t_brand ORDER BY id asc"                                            
    jdbc_paging_enabled => "true"                                            
    jdbc_page_size => "50000"                                            
    }
}
output {
  csv{
    #将id和品牌名字段输出到t_brand.csv文件
    fields => ["id", "names"]
    path => "/home/t_brand.csv"
}
}