Выходной плагин Logstash для JDBC/mySQL

Question

Я собираю данные Twitter и Instagram с помощью Logstash, и я хочу сохранить его в Elasticsearch, MongoDB и MySQL. Для Elasticearch и MongoDB доступны плагины вывода Logstash, но не для MySQL (это требование для сохранения этих данных в нескольких базах данных). Любое обходное решение для этого? Спасибо!

Answer 1

Вы должны установить плагин ouput-jdbc для logstash. Скачать с https://github.com/theangryangel/logstash-output-jdbc/tree/master и построить, установить

И тогда вы можете использовать, как это:.

input { 
    stdin{} 
} 

filter{ 
    json{ 
     source => "message" 
    } 
} 

output { 
    stdout{ 
     codec=>rubydebug{} 
    } 
    jdbc { 
    connection_string => "jdbc:mysql://192.168.119.202:3306/outMysql?user=root&password=root" 
     statement => ["INSERT INTO user(userName,ip) values(?,?)","userName","ip"] 
    } 
}