Logstash写入MongoDB数据库

1. 列出logstash-plugins

bin/logstash-plugin list
******

logstash-output-kafka
logstash-output-nagios
logstash-output-null
logstash-output-pagerduty
logstash-output-pipe
logstash-output-rabbitmq
logstash-output-redis


******

2. 根据output格式安装mongodb的output的plugin

bin/logstash-plugin install logstash-output-mongodb

3. 配置logstash的output配置文件

     mongodb {
            codec => line {format => "%{message}"}
            uri => "mongodb://asrlog-1:27017"
            database => "service"
            collection => "trace_log"
        }

4. 重启logstash

注意:即便是之前如下方式启动的logstash,也需要重启logstash,毕竟重新安装了output plugin(此处纠结了好一阵子。。。。。)

bin/logstash -f config/logstash-onlne.yml --config.reload.automatic &

5. 登录MongoDB,验证数据是否写入。

亲测可行,能够写入成功。

参考:https://www.elastic.co/guide/en/logstash/current/plugins-outputs-mongodb.html

不当之处,欢迎大神不吝赐教。

原文地址:https://www.cnblogs.com/zhzhang/p/7428089.html