刚方法主要是通过elasticsearch 5.x版本中的ingest node(新增的节点类型和功能)实现。ingest开启方式为:在 配置文件elasticsearch.yml中配置
node.ingest: true
Ingest 节点的基础原理,是:节点接收到数据之后,根据请求参数中指定的管道流 id,找到对应的已注册管道流,对数据进行处理,然后将处理过后的数据,按照 Elasticsearch 标准的 indexing 流程继续运行。
例如 将文档中的domain字段内容批量替换为abc
PUT _ingest/pipeline/set-domain
{
"description" : "update domain",
"processors" : [ {
"set" : {
"field": "domain",
"value": "abc"
}
} ]
}