Elasticsearch
Interfaz Python

Parámetros

Indexando un documento (es decir, añadiendo una muestra)

Instale la biblioteca de Python necesaria a través de:

$ pip install elasticsearch

Conéctese a Elasticsearch, cree un documento (por ejemplo, entrada de datos) e "indexe" el documento utilizando Elasticsearch.

from datetime import datetime
from elasticsearch import Elasticsearch

# Connect to Elasticsearch using default options (localhost:9200)
es = Elasticsearch()

# Define a simple Dictionary object that we'll index to make a document in ES
doc = {
    'author': 'kimchy',
    'text': 'Elasticsearch: cool. bonsai cool.',
    'timestamp': datetime.now(),
}

# Write a document
res = es.index(index="test-index", doc_type='tweet', id=1, body=doc)
print(res['created'])

# Fetch the document
res = es.get(index="test-index", doc_type='tweet', id=1)
print(res['_source'])

# Refresh the specified index (or indices) to guarantee that the document
#  is searchable (avoid race conditions with near realtime search)
es.indices.refresh(index="test-index")

# Search for the document
res = es.search(index="test-index", body={"query": {"match_all": {}}})
print("Got %d Hits:" % res['hits']['total'])

# Show each "hit" or search response (max of 10 by default)
for hit in res['hits']['hits']:
    print("%(timestamp)s %(author)s: %(text)s" % hit["_source"])

Conexión a un cluster

es = Elasticsearch(hosts=hosts, sniff_on_start=True, sniff_on_connection_fail=True, sniffer_timeout=60, sniff_timeout=10, retry_on_timeout=True)

Creando un índice vacío y configurando el mapeo

En este ejemplo, creamos un índice vacío (no indexamos ningún documento en él) definiendo su mapeo.

Primero, creamos una instancia de ElasticSearch y luego definimos el mapeo de nuestra elección. A continuación, verificamos si el índice existe y, de no ser así, lo creamos especificando los parámetros de index y body que contienen el nombre del índice y el cuerpo de la asignación, respectivamente.

from elasticsearch import Elasticsearch

# create an ElasticSearch instance
es = Elasticsearch()
# name the index
index_name = "my_index"
# define the mapping
mapping = {
    "mappings": {
        "my_type": {
                "properties": {
                    "foo": {'type': 'text'},
                    "bar": {'type': 'keyword'}
                }
            }
        }
    }
    
# create an empty index with the defined mapping - no documents added
if not es.indices.exists(index_name):
    res = es.indices.create(
        index=index_name,
        body=mapping
    )
    # check the response of the request
    print(res)
    # check the result of the mapping on the index
    print(es.indices.get_mapping(index_name))

Actualización parcial y actualización por consulta

Actualización parcial: se utiliza cuando se necesita una actualización parcial del documento, es decir, en el siguiente ejemplo, el name de campo del documento con id doc_id se actualizará a "John". Tenga en cuenta que si falta el campo, solo se agregará al documento.

doc = {
    "doc": {
        "name": "John"
    }
}
es.update(index='index_name',
          doc_type='doc_name',
          id='doc_id',
          body=doc)

Actualizar por consulta: se utiliza cuando es necesario para actualizar documentos que satisfacen una condición, es decir, en el siguiente ejemplo, actualizamos la antigüedad de los documentos cuyo campo de name coincide con 'John'.

q = {
  "script": {
    "inline": "ctx._source.age=23",
    "lang": "painless"
  },
  "query": {
    "match": {
        "name": "John"
    }
  }
}

es.update_by_query(body=q, 
                   doc_type='doc_name', 
                   index='index_name')