Recursos · Integración n8n

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

Por qué automatizar

¿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.

Conexión

¿Cómo se conecta Elasticsearch con n8n?

  1. 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.

  2. 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.

  3. 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 }}.

Acciones

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.

Matriz recursos × operaciones
RecursoCreateGetGet ManyUpdateDelete
Document✓✓✓✓✓
Index✓✓✓✓

Document

5 operaciones
01

Create a document

document.create

Lo 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.
Casos de uso
alimentar un índice de búsqueda con el volcado nocturno de una base, un documento por fila.
02

Delete a document

document.delete

Lo 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.
Casos de uso
eliminar la copia indexada de un registro archivado antes, para que la búsqueda deje de apuntar a algo que ya no existe.
03

Get a document

document.get

Lo 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.
Casos de uso
comprobar la versión indexada de una ficha antes de decidir si merece la pena actualizarla.
04

Get many documents

document.getAll

Lo 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:direction separados por comas.
Casos de uso
sacar todos los documentos de pedido con un estado concreto para un informe.
05

Update a document

document.update

Lo 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.
Casos de uso
mantener al día el stock de un producto indexado.

Index

4 operaciones
06

Create an index

index.create

Lo 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.
Casos de uso
crear el índice mensual de un registro de eventos antes de que llegue el primer documento.
07

Delete an index

index.delete

Lo 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.
Casos de uso
cerrar un ciclo de retención retirando el índice fechado más antiguo, una vez que la rotación ha confirmado que existe uno más reciente.
08

Get an index

index.get

Lo 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.
Casos de uso
leer el mapping vigente antes de que un flujo escriba un campo que quizá todavía no está tipado.
09

Get many indices

index.getAll

Lo 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.
Casos de uso
listar los índices existentes y recorrer el resultado para señalar cuáles debe borrar una rama de limpieza.
Necesitas ayuda

¿Necesitas ayuda para automatizar Elasticsearch con n8n?

El equipo te responde directamente.

Cada mensaje lo lee una persona.

FAQ

Elasticsearch y n8n, las dudas que vienen después

01¿La integración Elasticsearch n8n es gratuita?
Sí por el lado de n8n. El nodo Elasticsearch viene incluido con n8n, así que no hay nada que instalar ni coste adicional, tanto en n8n Cloud como en una instancia autoalojada en Community Edition con licencia Sustainable Use. Un flujo se comporta igual en los dos casos, de modo que lo que montas en uno se mueve al otro sin rehacerlo. Lo que cuesta Elasticsearch depende de tu propio despliegue y no se trata aquí. El credential que creas se queda dentro de tu instancia de n8n y lo reutilizan todos los flujos que hablan con el clúster.
02¿Qué credenciales pide el nodo Elasticsearch?
Basic auth y nada más. El credential pide un Username, un Password y una Base URL, que es el endpoint de tu aplicación Elasticsearch. Ese endpoint se saca dentro de Elasticsearch: entras en Deployments, eliges tu despliegue, abres Manage this deployment y copias el endpoint que figura en la sección Applications. Este nodo no ofrece opción de OAuth ni de clave de API. Hay un detalle que atasca a mucha gente: n8n solo conecta si la validación del certificado SSL funciona, así que un clúster con certificado autofirmado necesita activar Ignore SSL Issues en el credential.
03¿Qué límites tiene el nodo Elasticsearch en n8n?
El nodo cubre 2 recursos, documentos e índices, con 9 operaciones en total, y esa es toda la superficie disponible. Leer varios documentos pasa por Get Many con una Query escrita en Query DSL de Elasticsearch, y es Return All lo que hace que n8n encadene las páginas de resultados en vez de pararse en Limit. Lo que el nodo no expone sigue siendo accesible por otra vía: el nodo HTTP Request llama a cualquier endpoint de la API de Elasticsearch y reutiliza el mismo credential con la autenticación predefinida, así que un solo juego de claves cubre ambos caminos.
04¿Puede n8n reaccionar en tiempo real a un documento modificado en Elasticsearch?
No, porque esta integración no tiene nodo trigger. Nada dentro de n8n escucha al clúster para dispararse cuando se escribe o se borra un documento. Un flujo que toque Elasticsearch arranca de otra manera: con un Schedule Trigger que corre a intervalo fijo, con un Webhook de n8n, es decir una URL que otro servicio llama cuando ocurre un evento en su lado, o con el trigger de otra herramienta que ya tengas montada. El nodo Elasticsearch lee o escribe a continuación. En la práctica, un Get Many programado cuyo resultado se compara con la ejecución anterior hace las veces de detección de cambios.
05¿n8n o Make para Elasticsearch?
Depende sobre todo de dónde tengan que vivir los datos. Make está alojado por su editor, no ofrece autoalojamiento y factura por operación, de manera que un flujo que indexa miles de documentos cada noche se paga por volumen. n8n funciona en Cloud o en tu propio servidor, algo que pesa cuando el clúster está en una red privada y hacer pasar sus documentos por una plataforma externa levanta preguntas. En la lógica visual, los dos se construyen sobre un lienzo. Mira el alojamiento, el control del dato y el modelo de coste, y luego decide.