官方提供了sqlite插件。
因爲不是默認提供的插件,需要手工安裝:
bin/logstash-plugin install logstash-input-sqlite
在安裝的這一步遇到了很多坑,包括但不限於:
bin/logstash-plugin install /path/to/logstash-plugin.gem
按照官方示例(如下圖)配置了我的conf,並啓動:
報錯。。
主要考慮到上面的報錯在Google和百度都沒有找到參考。官方的示例又太簡單(單表),而且還不支持自定義statement語句,而我要找的內容又得關聯3張表才能查到。遂放棄
機緣巧合之下,Google到了一篇文章:《From a SQL database using Logstash》。 柳暗花明又一村。 sqlite本身和MySQL一樣也是數據庫(logstash和MySQL的demo早已跑通),那麼自然就可以使用jdbc來連接sqlite數據庫,也就可以使用statement來按照需求來獲取想要檢索的內容。