ElasticSearch实战（三十六）-Ingest Pipeline 多管道处理器

Posted 2021-10-09 张志翔ۤ

        在前文我们已经讲了 Ingest Pipeline 使用方法，除了单管道处理方式以外，它还支持多管道组合并行处理的方式对数据进行清洗，同时支持管道动态扩展和灵活组合，让数据清洗更加强大和实用。

        1、pipeline 创建

        我们提前定义多个pipeline，运用多管理处理器机制组合在一起，即可以独立运行，也可以组合运行，命令如下：

PUT _ingest/pipeline/pro001
{
  "description": "1.省份",
  "processors": [
    {
      "set": {
        "field": "area.pro",
        "value": "{
  {_source.pro}}"
      }
    },
    {
      "set": {
        "field": "area.city",
        "value": "{
  {_source.city}}"
      }
    }
  ]
}

DELETE _ingest/pipeline/company001
PUT _ingest/pipeline/company001
{
  "description": "2.公司",
  "processors": [
    {
      "set": {
        "field": "companyId",
        "value": "{
  {_id}}"
      }
    }
  ]
}