如何使用Filebeat配置的RabbitMQ

Question

我们使用ELK来控制我们的日志及Kibana可视化。我们有大约30种不同的日志类型，我们都从我们的电网机无论是从我们的客户端机器发送。

> logstash - - >弹 - > Kibana客户端机器与filebeat工作

我想将配置从改变： filebeat - > logstash - >弹 - > Kibana 至： filebeat - >的RabbitMQ - > logstash - >弹 - > Kibana

在弹性我创办这个yml例子 - 当RabbitMQ不是them之一。 是否有可能配置我们的系统，以这种方式？或者我必须使用： filebeat - > logstash1 - >的RabbitMQ - > logstash2 - >弹 - > Kibana

Answer 1

我不熟悉，在这种情况下RabbitMQ的，但是这似乎是在GitHub的仓库中的优势战胜了开放式的问题：

https://github.com/elastic/beats/issues/581

还有这个帖子从论坛弹性表示filebeat没有插件支持，所以我猜第一个选项是否定的：

https://discuss.elastic.co/t/filebeat-rabbitmq-plugin/55189

Logstash肯定支持的RabbitMQ作为输出：

https://www.elastic.co/guide/en/logstash/current/plugins-outputs-rabbitmq.html

Answer 2

我到底发现了一个很好的实现（尽管它不是一个“官方”之一）的FileBeat输出plugin。因为这里写下正确Beats队不打算支持RabbitMQ插件有人写它自己。

总之，为了使用plugin，你应该做到以下几点：

1. 在main.go文件： 包主

   import (
       "os"
   
       _ "github.com/sidleal/mqttout"
   
       "github.com/sidleal/countbeat/cmd"
   )
   
   func main() {
           if err := cmd.RootCmd.Execute(); err != nil {
               os.Exit(1)
           }
   }

2. 在CONFIG filebeat（yourbeat.yml）： 配置文件

   output.mqtt:
       host: "127.0.0.1"
       port: 1883
       topic: "mytopic"
       user: "myvhost:myuser"
        password: "mypassword"

3. amq.topic交换绑定到你想要的队列，把你的主题选路关键字。