Es pipeline:修订间差异

来自三线的随记
(创建页面,内容为“ GET _ingest/pipeline/_simulate { <nowiki> </nowiki> "pipeline": { <nowiki> </nowiki> "processors": [ <nowiki> </nowiki> { <nowiki> </nowiki> "split…”)
 
无编辑摘要
 
第64行: 第64行:
   ]
   ]
  }
  }
 
<br />
 
PUT _ingest/pipeline/testpipeline
{
<nowiki> </nowiki> "description":"test",
<nowiki> </nowiki>  "processors": [
<nowiki> </nowiki>    {
<nowiki> </nowiki>      "split": {
<nowiki> </nowiki>        "field": "message",
<nowiki> </nowiki>        "separator": "----",
<nowiki> </nowiki>        "target_field": "split"
<nowiki> </nowiki>      }
<nowiki> </nowiki>    },
<nowiki> </nowiki>    {
<nowiki> </nowiki>      "append": {
<nowiki> </nowiki>        "field": "test",
<nowiki> </nowiki>        "value": [
<nowiki> </nowiki>          "<nowiki>{{_source.split.0}}</nowiki>"
<nowiki> </nowiki>        ]
<nowiki> </nowiki>      }
<nowiki> </nowiki>    },
<nowiki> </nowiki>    {
<nowiki> </nowiki>      "append": {
<nowiki> </nowiki>        "field": "test2",
<nowiki> </nowiki>        "value": [
<nowiki> </nowiki>          "<nowiki>{{_source.split.1}}</nowiki>"
<nowiki> </nowiki>        ]
<nowiki> </nowiki>      }
<nowiki> </nowiki>    },{
<nowiki> </nowiki>      "remove":{
<nowiki> </nowiki>        "field":"split"
<nowiki> </nowiki>      }
<nowiki> </nowiki>    }
<nowiki> </nowiki>  ]
}
[[分类:Elasticsearch]]
[[分类:Elasticsearch]]

2020年4月15日 (三) 14:41的最新版本

GET _ingest/pipeline/_simulate
{
  "pipeline": {
    "processors": [
      {
        "split": {
          "field": "message",
          "separator": "----",
          "target_field": "split"
        }
      },
      {
        "append": {
          "field": "test1",
          "value": [
            "{{_source.split.0}}"
          ]
        }
      },
      {
        "append": {
          "field": "test2",
          "value": [
            "{{_source.split.1}}"
          ]
        }
      },{
        "remove":{
          "field":"split"
        }
      }
    ]
  },
  "docs": [
    {
      "_source": {
        "message": "abc----efff"
      }
    }
  ]
}


{
  "docs" : [
    {
      "doc" : {
        "_index" : "_index",
        "_type" : "_doc",
        "_id" : "_id",
        "_source" : {
          "test2" : [
            "efff"
          ],
          "message" : "abc----efff",
          "test1" : [
            "abc"
          ]
        },
        "_ingest" : {
          "timestamp" : "2020-04-15T05:33:07.554732Z"
        }
      }
    }
  ]
}


PUT _ingest/pipeline/testpipeline
{
  "description":"test",
    "processors": [
      {
        "split": {
          "field": "message",
          "separator": "----",
          "target_field": "split"
        }
      },
      {
        "append": {
          "field": "test",
          "value": [
            "{{_source.split.0}}"
          ]
        }
      },
      {
        "append": {
          "field": "test2",
          "value": [
            "{{_source.split.1}}"
          ]
        }
      },{
        "remove":{
          "field":"split"
        }
      }
    ]
}