RCP 与 RabbitMQ 连接到 Logstash

Question

我们目前正在将我们的系统连接到 elasticsearch。这个想法是将我们的数据推送到代理 (RabbitMQ)，然后将其传输到 elasticsearch。

由于河流已在最新的 elasticsearch 中被弃用，我能找到的唯一替代方案是在代理和 elasticsearch 之间使用 logstash。

它的工作原理是这样的：

Own System --> RabbitMQ --> Logstash --> elasticsearch

我可以成功连接所有系统，但我们有一些请求需要等待成功响应才能继续。我发现 RabbitMQ 的 RCP 正是我所需要的，因为我可以等到收到消费者的响应后再继续。

我的问题是我无法在任何地方找到如何配置 logstash 以使用回调队列。

有没有办法让logstash使用RCP？或者是否有其他方法可以在代理的帮助下将数据导入 elasticsearch？

Answer 1

队列代理提供的主要好处之一是能够分离您的系统并利用异步处理。如果您的系统确实需要同步确认一条记录已成功插入 ElasticSearch，那么让您的应用程序直接调用 ElasticSearch API 可能会更好。否则，如果数据在插入 ElasticSearch 时出现延迟，您的应用程序应该能够处理故障。