我最近开发了一个 C# Web 应用程序,它在主题类型的 RabbitMQ 交换上生成和使用消息,一切运行良好。我决定使用 ELK 堆栈来分析 RabbitMQ 日志,它也按预期工作得非常好,当我决定尝试记录所有产生和消费的消息时,我的麻烦就开始了。我按照本指南部署了 ELK 堆栈。
比我的麻烦开始了..这是摘录curl -XGET 'localhost:9200'
{
"name" : "dvv7m8h",
"cluster_name" : "elasticsearch",
"cluster_uuid" : "545-XOzEQ7W2C982ISVnng",
"version" : {
"number" : "6.8.4",
"build_flavor" : "default",
"build_type" : "deb",
"build_hash" : "bca0c8d",
"build_date" : "2019-10-16T06:19:49.319352Z",
"build_snapshot" : false,
"lucene_version" : "7.7.2",
"minimum_wire_compatibility_version" : "5.6.0",
"minimum_index_compatibility_version" : "5.0.0"
},
"tagline" : "You Know, for Search"
}
并且正如官方文档所述(
Rabbitmq 输入插件),我需要通过运行此命令来启用该插件bin/logstash-plugin install logstash-input-rabbitmq
,但是我没有可用的 bin/logstash-plugin 命令!我试图在万维网上寻找几乎所有地方,但三天后仍然没有结果。作为参考,我也会发布我的 logstash 配置文件。
input {
rabbitmq {
host => 'xxx.yyy.zz.nn:5672'
exchange => "my_exchange"
exchange_type => "topic"
id => "rabb"
}
}
}
output {
elasticsearch {
hosts => ["http://localhost:9200"]
index => "rabtest-%{+YYYY.MM.dd}"
}
}
谁能告诉我我错过了什么?该插件是否已经作为包在 logstash v.6.8.x 中提供?为什么我没有前面提到的安装插件的命令?谢谢。