› › ›

Процессор обработки труб

Выполняет другую трубу.

Таблица 31. Параметры обработки труб

Имя	Обязательно	По умолчанию	Описание
`name`	да	-	Имя обрабатываемой трубы. Поддерживает фрагменты шаблонов.
`description`	нет	-	Описание процессора. Полезно для описания назначения процессора или его конфигурации.
`if`	нет	-	Условное выполнение процессора. См. Условное выполнение процессора.
`ignore_failure`	нет	`false`	Игнорировать ошибки для процессора. См. Обработка ошибок обработки данных.
`on_failure`	нет	-	Обработка ошибок для процессора. См. Обработка ошибок обработки данных.
`tag`	нет	-	Идентификатор процессора. Полезно для отладки и метрик.

{
  "pipeline": {
    "name": "inner-pipeline"
  }
}

Имя текущей трубы можно получить из метаданных обработки по ключу _ingest.pipeline.

Пример использования этого процессора для вложенных труб:

Определение внутренней трубы:

PUT _ingest/pipeline/pipelineA
{
  "description" : "inner pipeline",
  "processors" : [
    {
      "set" : {
        "field": "inner_pipeline_set",
        "value": "inner"
      }
    }
  ]
}

Определение другой трубы, использующей ранее определенную внутреннюю трубу:

PUT _ingest/pipeline/pipelineB
{
  "description" : "outer pipeline",
  "processors" : [
    {
      "pipeline" : {
        "name": "pipelineA"
      }
    },
    {
      "set" : {
        "field": "outer_pipeline_set",
        "value": "outer"
      }
    }
  ]
}

Теперь при индексировании документа с применением внешней трубы будет выполняться внутренняя труба из внешней трубы:

PUT /my-index/_doc/1?pipeline=pipelineB
{
  "field": "value"
}

Ответ от запроса индексации:

{
  "_index": "my-index",
  "_type": "_doc",
  "_id": "1",
  "_version": 1,
  "result": "created",
  "_shards": {
    "total": 2,
    "successful": 1,
    "failed": 0
  },
  "_seq_no": 66,
  "_primary_term": 1
}

Индексированный документ:

{
  "field": "value",
  "inner_pipeline_set": "inner",
  "outer_pipeline_set": "outer"
}

© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/7.17/pipeline-processor.html