ElasticSearch实战（三十八）-Ingest Pipeline 逻辑条件判断

Posted 2021-10-09 张志翔ۤ

        在 Ingest Pipeline 中，可以基于 painless 脚本，编写逻辑条件进行判断，可以做一些事情，比如满足某个条件再进行数据清洗，如果不满足就不进行数据清洗等类似操作，大大增加了 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}}"
      }
    }
  ]
}

PUT _ingest/pipeline/company001
{
  "description": "2.公司",
  "processors": [
    {
      "set": {
        "if": "ctx._id==\'88888\'", 
        "field": "companyId",
        "value": "{
  {_id}}"
      }
    }