python-3.x - 从 Kibana 到 Python 的查询？

Question

PUT _ingest/pipeline/trim
{
  "description" : "trims my name field",
  "processors" : [ {
      "trim" : {
        "field": "country"
      }
  } ]
}

POST suppliers/_update_by_query?pipeline=trim

我想要上述 Kibana 语法的 Python 语法

Answer 1

我使用邮递员和 curl.trillworks.com

import requests

headers = {
    'Content-Type': 'application/json',
}

data = '{\n  "description" : "trims my name field",\n  "processors" : [ {\n      "trim" : {\n        "field": "country"\n      }\n  } ]\n}'

response = requests.put('http://localhost:9200/_ingest/pipeline/trim', headers=headers, data=data)

但也许你应该检查 python ES 客户端

Answer 2

对于 Python，您需要导入某些库

from elasticsearch.client.ingest import IngestClient
from elasticsearch import Elasticsearch
es=Elasticsearch()
p = IngestClient(es)


body = {
        "description" : "trims my name field",
        "processors": [
            {
                "trim": {
                    "field": "country"
                    }
                }
            ]
        }
p.put_pipeline(id="trim",body=body)
es.update_by_query(index="suppliers",pipeline="trim")