elasticsearch - 将 Elasticsearch 与 RabbitMQ 结合使用

Question

我有一个 RabbitMQ 队列，它提取一些需要传输到 Elastic Search 的文档。

如何将 Elastic Search 创建为消费者，以便 ES 充当文档队列的消费者。

可能的选择:

1. 使用 RabbitMQ River？
2. 使用 RabbitMQ 插件？ (怎么做)
3. 其他 ?

有人可以发布示例吗？

Answer 1

在你的 ELK 上创建配置文件/etc/logstash/conf.d/anyfile.conf

input {
   rabbitmq {
      host => 'rabbit.example.com'
      queue => 'my_queue_name'
      exchange => "my_exchange_name"
      key => 'my_logs'
      durable => true
   }
}
output {
   elasticsearch {
      host => "elk.example.com"
   }
}