- Inicio
- Recursos
- Integraciones
- Elasticsearch
Integración Elasticsearch n8nAutomatiza Elasticsearch con n8n.
¿Tu índice sigue el ritmo de tus datos? La integración Elasticsearch n8n añade un nodo con 9 operaciones repartidas en 2 recursos, documentos e índices, para crear, leer, actualizar y borrar desde un flujo de trabajo programado, sin abrir la consola.
Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth
¿Qué resuelve la integración Elasticsearch n8n?
El nodo Elasticsearch viene incluido en n8n y habla con tu despliegue de Elasticsearch a través de su API, con un credential (unas credenciales que se guardan una sola vez dentro de n8n) en basic auth: usuario, contraseña y URL base. Cubre 2 recursos: documentos, con crear, leer, listar, actualizar y borrar, e índices, con crear, leer, listar y borrar. Son 9 operaciones en total, sin nada que instalar.
Primer caso, el catálogo que se puede buscar. Un Schedule Trigger lee cada mañana las filas nuevas de una base Microsoft SQL y document.create las deposita en un índice con Bulk Create activado, así el lote pasa por la operación bulk en lugar de una petición por fila. El equipo busca sobre datos frescos sin pedirle un export a nadie.
Segundo caso, la ficha que se mantiene viva. Cuando un pedido cambia de estado antes en el flujo, document.update reescribe los campos de ese Document ID y document.get relee el resultado antes de seguir. El mismo montaje sirve para una ficha enriquecida desde MongoDB o para un registro que llega de Postgres.
Tercer caso, el mantenimiento de los índices. index.getAll enumera lo que ya existe, index.create abre el índice del mes con sus Mappings y sus Settings, y index.delete retira el más antiguo. Esa rotación corre sola y no obliga a nadie a abrir una terminal.
Conviene saber dónde termina el nodo. La búsqueda se hace con la opción Query de Get Many, escrita en Query DSL de Elasticsearch, y el nodo solo expone documentos e índices. Lo que queda fuera de esos 2 recursos queda también fuera de las 9 operaciones. Para esas llamadas, el nodo HTTP Request ataca cualquier endpoint de la API de Elasticsearch y reutiliza el mismo credential con la autenticación predefinida, de modo que las claves viven en un único sitio.
Hay un punto que condiciona el diseño: esta herramienta no tiene nodo trigger en n8n, así que nada reacciona por su cuenta a un cambio ocurrido dentro del clúster. El flujo arranca en otro sitio, con un Schedule Trigger a intervalo fijo, con un Webhook de n8n (una URL que otro servicio llama cuando pasa algo de su lado) o con el trigger de otra herramienta, y el nodo Elasticsearch escribe o lee después. Si todavía estás comparando plataformas, la Reseña n8n entra en ese detalle.
¿Cómo se conecta Elasticsearch con n8n?
- 01
Crea el credential de Elasticsearch
En n8n, abre el menú Credentials y añade un credential de Elasticsearch. El nodo solo admite basic auth, así que necesitas un Username y un Password de una cuenta de Elasticsearch que ya tenga un despliegue. El credential se crea una vez y se reutiliza en todos los flujos, por eso el nodo lo ofrece después en una lista desplegable.
- 02
Copia el endpoint del despliegue
El tercer campo es la Base URL, el endpoint de tu aplicación Elasticsearch. Dentro de Elasticsearch, entra en Deployments, elige tu despliegue y abre Manage this deployment. En la sección Applications, copia el endpoint que aparece para la aplicación Elasticsearch y pégalo en n8n como Base URL. Ningún otro campo interviene.
- 03
Elige el recurso en el nodo
Coloca un nodo Elasticsearch en el lienzo y selecciona el credential de su lista. Elige el recurso, Document o Index, y luego la operación. Todas las operaciones salvo Get Many sobre índices piden un Index ID, y n8n detiene la ejecución cuando un campo requerido se queda vacío: apunta a un nombre fijo o a una expresión como
{{ $json.index }}.
Las 9 operaciones del nodo Elasticsearch
El nodo Elasticsearch expone 9 operaciones en 2 recursos. Para cada una: el nodo tal como lo configuras en n8n, los campos obligatorios y nuestras notas de campo.
Índice de operaciones
Document
5 operacionesCreate a document
document.createLo que ves en n8n
Notas y casos de uso
Indexa un documento nuevo dentro de un índice existente y devuelve el identificador que Elasticsearch le asigna.
Parámetros clave
- Index ID: el índice que recibe el documento, a menudo
{{ $json.index }}cuando el nombre viene de un nodo anterior. - Data to Send: con Auto-Map Input Data to Columns el item entra tal cual si sus propiedades ya coinciden con los campos del documento; con Define Below for Each Column defines a mano cada Field Name y cada Field Value.
- Bulk Create: usa la operación bulk para crear varios documentos de una vez.
Delete a document
document.deleteLo que ves en n8n
Notas y casos de uso
Quita un documento de un índice. El borrado va dirigido: el índice sigue en pie con todo lo demás que contiene.
Parámetros clave
- Index ID: el índice del documento a borrar.
- Document ID: el identificador exacto del documento, no un valor de campo que parezca un título.
- Bulk Delete: cambia a la operación bulk cuando una ejecución tiene que limpiar varios documentos.
Get a document
document.getLo que ves en n8n
Notas y casos de uso
Lee un documento concreto por su identificador y entrega sus campos guardados al nodo siguiente.
Parámetros clave
- Index ID y Document ID: los dos son requeridos y localizan el documento sin pasar por una búsqueda.
- Simplify: devuelve una versión reducida de la respuesta en vez del dato en bruto, más cómoda de mapear después.
- Source Includes y Source Excludes: listas de campos de origen separadas por comas, para conservarlos o dejarlos fuera de la respuesta.
Get many documents
document.getAllLo que ves en n8n
Notas y casos de uso
Consulta un índice y trae los documentos que coinciden. Es la única puerta de entrada a la búsqueda que tiene el nodo.
Parámetros clave
- Index ID: el índice donde buscar.
- Query: la consulta en sí, en Query DSL de Elasticsearch, por ejemplo
{ "query": { "term": { "user.id": "john" } } }. - Return All: activado, n8n encadena las páginas de la API y trae todos los resultados; desactivado, Limit fija el número máximo de documentos.
- Sort: una lista de pares
field:directionseparados por comas.
Update a document
document.updateLo que ves en n8n
Notas y casos de uso
Reescribe los campos de un documento que ya existe y deja intacto el resto del índice.
Parámetros clave
- Document ID: el documento que se modifica, normalmente arrastrado desde el nodo que lo encontró.
- Fields to Send: la lista de campos a escribir, cada uno con su Field Name y su Field Value.
- Refresh: True refresca los shards afectados para que el cambio se vea enseguida en la búsqueda, Wait For espera a un refresco y False no hace nada.
- Bulk Update: recurre a la operación bulk para un lote de documentos.
Index
4 operacionesCreate an index
index.createLo que ves en n8n
Notas y casos de uso
Abre un índice nuevo, con su estructura definida desde el principio en lugar de parcheada más tarde.
Parámetros clave
- Index ID: el nombre del índice a crear, muchas veces construido con una fecha dentro de una expresión.
- Mappings: el objeto de mapping que tipa los campos, por ejemplo
{ "mappings": { "properties": { "field1": { "type": "text" } } } }. - Settings: el objeto de configuración del índice, con el número de shards y de réplicas incluido.
- Aliases: el objeto de alias que engancha uno o varios alias al índice.
Delete an index
index.deleteLo que ves en n8n
Notas y casos de uso
Borra un índice entero con todos los documentos que guarda. Después no hay marcha atrás, así que esta operación va detrás de una condición o de una validación manual.
Parámetros clave
- Index ID: el único campo, y espera el nombre del índice, no un alias de los que usas a diario en las consultas.
Get an index
index.getLo que ves en n8n
Notas y casos de uso
Devuelve la definición de un índice: sus mappings, sus settings y sus alias tal como los guarda Elasticsearch.
Parámetros clave
- Index ID: el índice que se inspecciona.
- Include Defaults: activado, la respuesta incluye además todos los ajustes por defecto, útil cuando comparas dos clústeres.
- Flat Settings: devuelve los settings en formato plano en lugar de un objeto anidado.
- Ignore Unavailable: decide si una petición dirigida a un índice ausente devuelve un error.
Get many indices
index.getAllLo que ves en n8n
Notas y casos de uso
Enumera los índices del despliegue. Es la única operación que no pide ningún identificador, y por eso encaja como primer paso de un flujo de mantenimiento.
Parámetros clave
- Return All: activado, suben todos los índices; desactivado, Limit marca el máximo devuelto.
¿Necesitas ayuda para automatizar Elasticsearch con n8n?
El equipo te responde directamente.
Cada mensaje lo lee una persona.
