Запрос из Kibana в Python?

Question

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

POST suppliers/_update_by_query?pipeline=trim

Я хочу синтаксис Python для приведенного выше синтаксиса Kibana

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")