节点 Ingest Elasticsearch

A veces necesitamos indexar el documento antes de convertirlo. Por ejemplo, queremos eliminar un campo del documento o renombrarlo y luego indexarlo. Esto se maneja por el nodo de ingesta.

Cada nodo en el clúster tiene la función de extracción, pero también se puede personalizar para que solo sea procesado por nodos específicos.

Paso

El trabajo del nodo de ingesta implica dos pasos-

• Crear pipeline

• Establecer archivo

Crear pipeline

Primero creamos un pipeline que contiene procesadores y luego ejecutamos el pipeline, como se muestra a continuación-

PUT _ingest/pipeline/int-converter
{
　　　"description": "convierte el contenido del campo seq en un entero"
　　　"processors": [
　　　　　　{
　　　　　　　　　"convert": {
　　　　　　　　　　　　"field": "seq",
　　　　　　　　　　　　"type": "integer"
　　　　　　　　　}
　　　　　　}
　　　]
}

Al ejecutar el código anterior, obtenemos el siguiente resultado-

{
　　　"acknowledged": true
}

Establecer archivo

A continuación, utilizamos el convertidor de tubería para crear un documento.

PUT　/logs/_doc/1?pipeline=int-converter
{
　　　"seq":"21""
　　　"name": "w"3codebox",
　　　"Addrs": "Hyderabad"
}

Después de ejecutar el código anterior, obtenemos la respuesta siguiente:

{
　　　"_index": "logs",
　　　"_type": "_doc",
　　　"_id": ""1""
　　　"_version": "　1,
　　　"result": "created",
　　　"_shards": {
　　　　　　"total":　2,
　　　　　　"successful":　1,
　　　　　　"failed": 0
　　　},
　　　"_seq_no": 0,
　　　"_primary_term": "　1
}

A continuación, utilizamos el comando GET para buscar el documento creado anteriormente, como se muestra a continuación-

GET　/logs/_doc/1

Al ejecutar el código anterior, obtenemos el siguiente resultado-

{
　　　"_index": "logs",
　　　"_type": "_doc",
　　　"_id": ""1""
　　　"_version": "　1,
　　　"_seq_no": 0,
　　　"_primary_term": "　1,
　　　"found": true,
　　　"_source": {
　　　　　　"Addrs": "Hyderabad"
　　　　　　"name": "w"3codebox",
　　　　　　"seq":　21
　　　}
}

Puedes verlo en la parte superior21Convertirse en un entero.

Sin tuberías

Ahora, no necesitamos usar tuberías para crear documentos.

PUT　/logs/_doc/2
{
　　　"seq":"11""
　　　"name":"Tutorix",
　　　"Addrs":"Secunderabad"
}
GET　/logs/_doc/2

Al ejecutar el código anterior, obtenemos el siguiente resultado-

{
　　　"_index": "logs",
　　　"_type": "_doc",
　　　"_id": ""2""
　　　"_version": "　1,
　　　"_seq_no": "　1,
　　　"_primary_term": "　1,
　　　"found": true,
　　　"_source": {
　　　　　　"seq": ""11""
　　　　　　"name": "Tutorix",
　　　　　　"Addrs": "Secunderabad"
　　　}
}

Puedes verlo aquí11es una cadena de caracteres sin tubería.