› › ›

脚本处理器

脚本处理器编辑

对传入文档运行内联或存储的脚本。脚本在 ingest 上下文中运行。

脚本处理器使用脚本缓存来避免为每个传入文档重新编译脚本。为了提高性能，请确保在生产环境中使用脚本处理器之前，脚本缓存的大小设置正确。

表 39. 脚本选项

名称	必填	默认值	描述
`lang`	否	"painless"	脚本语言.
`id`	否	-	存储的脚本的 ID。如果未指定 `source`，则此参数是必需的。
`source`	否	-	内联脚本。如果未指定 `id`，则此参数是必需的。
`params`	否	-	包含脚本参数的对象。
`description`	否	-	处理器的描述。用于描述处理器的用途或其配置。
`if`	否	-	有条件地执行处理器。请参阅有条件地运行处理器。
`ignore_failure`	否	`false`	忽略处理器的故障。请参阅处理管道故障。
`on_failure`	否	-	处理处理器的故障。请参阅处理管道故障。
`tag`	否	-	处理器的标识符。用于调试和指标。

访问源字段编辑

脚本处理器将每个传入文档的 JSON 源字段解析为一组映射、列表和基元。要使用 Painless 脚本访问这些字段，请使用映射访问运算符：ctx['my-field']。您也可以使用简写形式 ctx.<my-field> 语法。

脚本处理器不支持 ctx['_source']['my-field'] 或 ctx._source.<my-field> 语法。

以下处理器使用 Painless 脚本从 env 源字段中提取 tags 字段。

response = client.ingest.simulate(
  body: {
    pipeline: {
      processors: [
        {
          script: {
            description: "Extract 'tags' from 'env' field",
            lang: 'painless',
            source: "\n            String[] envSplit = ctx['env'].splitOnToken(params['delimiter']);\n            ArrayList tags = new ArrayList();\n            tags.add(envSplit[params['position']].trim());\n            ctx['tags'] = tags;\n          ",
            params: {
              delimiter: '-',
              position: 1
            }
          }
        }
      ]
    },
    docs: [
      {
        _source: {
          env: 'es01-prod'
        }
      }
    ]
  }
)
puts response

POST _ingest/pipeline/_simulate
{
  "pipeline": {
    "processors": [
      {
        "script": {
          "description": "Extract 'tags' from 'env' field",
          "lang": "painless",
          "source": """
            String[] envSplit = ctx['env'].splitOnToken(params['delimiter']);
            ArrayList tags = new ArrayList();
            tags.add(envSplit[params['position']].trim());
            ctx['tags'] = tags;
          """,
          "params": {
            "delimiter": "-",
            "position": 1
          }
        }
      }
    ]
  },
  "docs": [
    {
      "_source": {
        "env": "es01-prod"
      }
    }
  ]
}

处理器生成

{
  "docs": [
    {
      "doc": {
        ...
        "_source": {
          "env": "es01-prod",
          "tags": [
            "prod"
          ]
        }
      }
    }
  ]
}

访问元数据字段编辑

您还可以使用脚本处理器来访问元数据字段。以下处理器使用 Painless 脚本设置传入文档的 _index。

response = client.ingest.simulate(
  body: {
    pipeline: {
      processors: [
        {
          script: {
            description: 'Set index based on `lang` field and `dataset` param',
            lang: 'painless',
            source: "\n            ctx['_index'] = ctx['lang'] + '-' + params['dataset'];\n          ",
            params: {
              dataset: 'catalog'
            }
          }
        }
      ]
    },
    docs: [
      {
        _index: 'generic-index',
        _source: {
          lang: 'fr'
        }
      }
    ]
  }
)
puts response

POST _ingest/pipeline/_simulate
{
  "pipeline": {
    "processors": [
      {
        "script": {
          "description": "Set index based on `lang` field and `dataset` param",
          "lang": "painless",
          "source": """
            ctx['_index'] = ctx['lang'] + '-' + params['dataset'];
          """,
          "params": {
            "dataset": "catalog"
          }
        }
      }
    ]
  },
  "docs": [
    {
      "_index": "generic-index",
      "_source": {
        "lang": "fr"
      }
    }
  ]
}

处理器将文档的 _index 从 generic-index 更改为 fr-catalog。

{
  "docs": [
    {
      "doc": {
        ...
        "_index": "fr-catalog",
        "_source": {
          "lang": "fr"
        }
      }
    }
  ]
}

« 重新路由处理器设置处理器 »