- Accueil
- Ressources
- Intégrations
- Elasticsearch
Intégration Elasticsearch n8nAutomatiser Elasticsearch avec n8n.
Un index qui date, c'est une recherche qui ment. L'intégration Elasticsearch n8n pose dans le workflow un nœud de 9 opérations réparties sur 2 ressources, les documents et les index, pour écrire, relire et nettoyer la donnée sans repasser par la console.
Avis vérifiés sur Trustpilot · Agence IA, automatisation & growth
À quoi sert l'intégration Elasticsearch n8n ?
Le nœud Elasticsearch est livré avec n8n et parle à ton déploiement Elasticsearch via son API, avec un credential (un jeu d'identifiants enregistré une fois dans n8n) en basic auth : un nom d'utilisateur, un mot de passe, une URL de base. Il couvre 2 ressources. Côté documents : créer, lire, lister, mettre à jour, supprimer. Côté index : créer, lire, lister, supprimer. Soit 9 opérations, sans rien installer.
Premier cas, le journal d'événements consultable. Un Schedule Trigger relit toutes les heures les nouvelles lignes d'une base Postgres, et document.create les dépose dans un index avec Bulk Create activé, ce qui passe le lot par l'opération bulk au lieu d'une requête par ligne. L'équipe cherche dans l'historique sans demander un export à personne.
Deuxième cas, la fiche qui reste à jour. Un formulaire suivi dans Google Sheets change de statut, document.update réécrit les champs concernés pour ce Document ID, et document.get relit le résultat avant que la branche suivante ne s'exécute. Même logique pour une fiche produit enrichie depuis MySQL.
Troisième cas, l'entretien des index. index.getAll liste ce qui existe déjà, index.create ouvre l'index du mois avec ses Mappings et ses Settings, index.delete retire le plus ancien. Une rotation comme celle-là tourne toute seule et n'oblige personne à ouvrir un terminal.
Là où le nœud s'arrête est simple à poser. La recherche passe par l'option Query de Get Many, écrite en Query DSL Elasticsearch, et le nœud n'expose que les documents et les index. Tout ce qui sort de ces 2 ressources sort aussi de la liste des 9 opérations. Pour ces appels, le nœud HTTP Request attaque n'importe quel endpoint de l'API Elasticsearch en réutilisant le même credential via l'authentification prédéfinie : les identifiants restent à un seul endroit.
Un point à anticiper : cet outil n'a pas de nœud trigger dans n8n, donc rien ne réagit tout seul à un changement survenu dans le cluster. Le workflow démarre ailleurs, avec un Schedule Trigger à intervalle fixe, un Webhook n8n (une URL qu'un service tiers appelle quand il se passe quelque chose chez lui) ou le trigger d'un autre outil, et le nœud Elasticsearch écrit ou lit derrière. Si le choix de la plateforme n'est pas encore tranché, l'Avis n8n traite la question.
Comment connecter Elasticsearch à n8n ?
- 01
Créer le credential Elasticsearch
Dans n8n, ouvre le menu Credentials et ajoute un credential Elasticsearch. Le nœud accepte uniquement la basic auth : il te faut donc un Username et un Password d'un compte Elasticsearch qui dispose déjà d'un déploiement. Le credential se crée une fois et sert dans tous les workflows, c'est pour ça que le nœud le propose ensuite dans une liste déroulante.
- 02
Récupérer l'endpoint du déploiement
Le troisième champ est la Base URL, l'endpoint de ton application Elasticsearch. Dans Elasticsearch, va dans Deployments, sélectionne ton déploiement, puis Manage this deployment. Dans la section Applications, copie l'endpoint affiché pour l'application Elasticsearch et colle-le dans n8n comme Base URL. Aucun autre champ n'entre en jeu.
- 03
Choisir la ressource dans le nœud
Pose un nœud Elasticsearch sur le canvas et sélectionne le credential dans sa liste. Choisis la ressource, Document ou Index, puis l'opération. Toutes les opérations sauf Get Many sur les index demandent un Index ID, et n8n bloque l'exécution quand un champ requis reste vide : pointe donc un nom fixe ou une expression du type
{{ $json.index }}.
Les 9 opérations du nœud Elasticsearch
Le nœud Elasticsearch expose 9 opérations sur 2 ressources. Pour chacune : le nœud tel que tu le configures dans n8n, les champs obligatoires, et nos notes de terrain.
Sommaire des opérations
Document
5 opérationsCreate a document
document.createCe que tu vois dans n8n
Notes & cas d'usage
Indexe un nouveau document dans un index existant et renvoie l'identifiant qu'Elasticsearch lui a attribué.
Paramètres clés
- Index ID : l'index qui reçoit le document, souvent
{{ $json.index }}quand le nom vient d'un nœud précédent. - Data to Send : Auto-Map Input Data to Columns envoie l'item entrant tel quel quand ses propriétés correspondent déjà aux champs du document ; Define Below for Each Column te laisse saisir chaque Field Name et Field Value à la main.
- Bulk Create : passe par l'opération bulk pour créer plusieurs documents d'un coup.
Delete a document
document.deleteCe que tu vois dans n8n
Notes & cas d'usage
Retire un document d'un index. La suppression est ciblée : l'index reste en place avec tout ce qu'il contient par ailleurs.
Paramètres clés
- Index ID : l'index qui contient le document à supprimer.
- Document ID : l'identifiant exact du document, pas une valeur de champ qui ressemble à un titre.
- Bulk Delete : bascule sur l'opération bulk quand une exécution doit nettoyer plusieurs documents.
Get a document
document.getCe que tu vois dans n8n
Notes & cas d'usage
Lit un document précis par son identifiant et transmet ses champs stockés au nœud suivant.
Paramètres clés
- Index ID et Document ID : les deux sont requis, ils localisent le document sans passer par une recherche.
- Simplify : renvoie une version allégée de la réponse au lieu de la donnée brute, plus facile à mapper ensuite.
- Source Includes et Source Excludes : des listes de champs source séparées par des virgules, à garder ou à écarter de la réponse.
Get many documents
document.getAllCe que tu vois dans n8n
Notes & cas d'usage
Interroge un index et ramène les documents qui correspondent. C'est le seul point d'entrée de recherche du nœud.
Paramètres clés
- Index ID : l'index dans lequel chercher.
- Query : la requête elle-même, en Query DSL Elasticsearch, par exemple
{ "query": { "term": { "user.id": "john" } } }. - Return All : activé, n8n enchaîne les pages de l'API et rapporte tous les résultats ; désactivé, Limit fixe le nombre maximal de documents renvoyés.
- Sort : une liste de paires
field:directionséparées par des virgules.
Update a document
document.updateCe que tu vois dans n8n
Notes & cas d'usage
Réécrit les champs d'un document qui existe déjà, sans toucher au reste de l'index.
Paramètres clés
- Document ID : le document à modifier, généralement repris du nœud qui l'a trouvé.
- Fields to Send : la liste des champs à écrire, chacun avec son Field Name et sa Field Value.
- Refresh : True rafraîchit les shards concernés pour que la modification soit visible tout de suite en recherche, Wait For attend un rafraîchissement, False ne fait rien.
- Bulk Update : utilise l'opération bulk pour un lot de documents.
Index
4 opérationsCreate an index
index.createCe que tu vois dans n8n
Notes & cas d'usage
Ouvre un nouvel index, avec sa structure définie à la création plutôt que rafistolée après coup.
Paramètres clés
- Index ID : le nom de l'index à créer, souvent construit à partir d'une date dans une expression.
- Mappings : l'objet de mapping qui type les champs, par exemple
{ "mappings": { "properties": { "field1": { "type": "text" } } } }. - Settings : l'objet de configuration de l'index, nombre de shards et de réplicas compris.
- Aliases : l'objet d'alias qui rattache un ou plusieurs alias à l'index.
Delete an index
index.deleteCe que tu vois dans n8n
Notes & cas d'usage
Supprime un index entier et tous les documents qu'il contient. Rien ne se rattrape ensuite, donc cette opération se place derrière une condition ou une validation manuelle.
Paramètres clés
- Index ID : le seul champ, et il attend le nom de l'index, pas un alias utilisé dans les requêtes du quotidien.
Get an index
index.getCe que tu vois dans n8n
Notes & cas d'usage
Renvoie la définition d'un index : ses mappings, ses settings et ses alias tels qu'Elasticsearch les stocke.
Paramètres clés
- Index ID : l'index à inspecter.
- Include Defaults : activé, la réponse embarque aussi tous les réglages par défaut, pratique quand on compare deux clusters.
- Flat Settings : renvoie les settings au format plat plutôt qu'en objet imbriqué.
- Ignore Unavailable : décide si une requête visant un index absent renvoie une erreur.
Get many indices
index.getAllCe que tu vois dans n8n
Notes & cas d'usage
Liste les index du déploiement. C'est la seule opération qui ne demande aucun identifiant, ce qui en fait la première étape naturelle d'un workflow de maintenance.
Paramètres clés
- Return All : activé, tous les index remontent ; désactivé, Limit fixe le nombre maximal renvoyé.
Besoin d'aide pour automatiser Elasticsearch avec n8n ?
L'équipe te répond directement.
Chaque message est lu par une personne.
