Elasticsearch RabbitMQ river



我目前正在通过rabbitmq添加文档更改,以通过批量api进行弹性搜索(这就像一个魅力一样),我想知道当这种情况发生时,是否有任何机制可以向另一个rabbitmqqueue发送消息。我想在弹性搜索中应用更改后对文档进行处理。

这可能吗?一种解决方案可能是,我在其间添加一个工作人员侦听的队列,将其添加到弹性搜索队列和新更改队列中,但这听起来有点俗气。。。

理想的解决方案是:

当我在rabbit中确认消息时,它能把消息放入不同的队列?

答案是否定的。

我建议,在插入到elasticsearch中的代码创建了一条新消息并将其放入一个新的rabbit队列后,它会确认旧消息。

最新更新