如何在已编入索引的文档上使用摄取管道？

Question

我一直在使用 FOSElasticaBundle 将我的文档（它们是来自通过 Doctrine 保存在数据库中的 Symfony 项目的实体）索引到 Elastic Search 中。FOSElastica 在所有文档之后进行自动映射和索引。问题是我想对每个文档（已经编入索引的和将要编入索引的文件）应用一些操作，所以管道和无痛似乎是一个很好的解决方案。但是，我无法理解如何将管道应用于已编入索引的文档，您知道如何操作吗？我已经看到您可以在 ES 请求后添加“pipeline=my_pipeline_name”，但您可以为单个文档执行此操作，而我希望它影响所有文档。

Answer 1

您可以在将数据从一个索引移动到另一个索引时使用Pipeline。

您需要使用Reindex API，以便在movement/ingestion_process从一个索引到另一个索引期间对数据执行它。

注意：这是索引级别的操作，这意味着它会影响所有文档。

以下是步骤摘要：

• 创建一个temporary_index，

• Reindex fromsource_index以temporary_index使用Reindex API。还包括管道（下面提供的示例查询）

• 删除并重新创建source_index. 确保在创建索引时也包含映射。

• 在没有管道的情况下使用source_index目标名称和temporary_index源名称执行相同的查询

以下是您如何通过管道使用 Reindex API

POST _reindex

{

  "source": {

    "index": "source_index_name"

  },

  "dest": {

    "index": "temporary_index",

    "pipeline": "some_ingest_pipeline"

  }

}

让我知道这是否有帮助！