n8n-connector

Met de Entity Enricher community-node voor n8n kun je geautomatiseerde verrijkingspijplijnen bouwen met een visuele drag-and-drop-editor. Verbind met 400+ apps zonder code te schrijven.

Installatie

Installeer de community node in je n8n-instantie:

npm install n8n-nodes-entity-enricher

Of installeer via de n8n-UI: ga naar Instellingen → Community Nodes en zoek naar n8n-nodes-entity-enricher.

Vereisten

API-sleutel— Maak een organization-toegangssleutel aan in Entity Enricher. Zie de documentatie over API-sleutels voor meer details. Het sleutelformaat is ent_XXXXXXXXXXXX.
Basis-URL— De URL van je Entity Enricher-instance (bijv. https://entityenricher.ai of je zelf-gehoste URL).
Credential instellen— Maak in n8n een Entity Enricher API-credential aan met je API-sleutel en base-URL. Alle nodes gebruiken deze credential. Een organisatietoegangssleutel werkt onafhankelijk van elk gebruikersaccount — de aanbeveling voor duurzame service-naar-service-workflows.
OAuth2 (alternatief)— Liever verbinden met je account? Maak in plaats daarvan een Entity Enricher OAuth2 API-credential aan: kopieer de OAuth-redirect-URL die n8n toont, registreer daarmee een OAuth-client in Entity Enricher onder API Keys → Verbonden apps → OAuth Clients (owner-rol), plak de client-ID in n8n en klik op Mijn account verbinden. De verbinding handelt met je eigen rol en is op elk moment intrekbaar onder Verbonden apps. Selecteer de credential op de node met de parameter Authenticatie.
  1. 1De naam die in Connected Apps wordt getoond
  2. 2De OAuth Redirect URL van n8n, exact gekopieerd
  3. 3Geeft de client-ID die je in n8n plakt
Een client kan achteraf niet worden bewerkt — de redirect-URL ligt bij het aanmaken vast, dus een tweede n8n-instantie krijgt een eigen client, en zodra je er een verwijdert, wordt elke verbinding die erdoorheen liep direct ingetrokken.

Beschikbare bewerkingen

De connector biedt 18 bewerkingen in 7 resourcecategorieën:

ResourceBewerkingBeschrijving
EnrichmentEnrich EntityVerrijk één entity — kies gewoon een schema; het beste model en de beste strategie van je organization worden automatisch gekozen. Streamt resultaten via SSE met realtime voortgang.
EnrichmentEnrich Entity AdvancedVerrijk één entity met volledige controle over modellen, fusion, strategie, classificatie en gestructureerde output.
EnrichmentBatch EnrichVerrijk alle invoeritems als één batch met het automatische model en de automatische strategie. Parallelle verwerking met voortgangsregistratie per entity.
EnrichmentBatch Enrich AdvancedVerrijk alle invoeritems als één batch met de volledige parameterset.
SchemaList SchemasToon beschikbare opgeslagen schema's ter selectie in enrichment-workflows.
SchemaGet Schema DetailsHaal de volledige schema-inhoud op met geëxtraheerde belangrijkste eigenschappen voor een specifiek schema.
SchemaGenerate SampleGenereer in één job 1..N realistische JSON-voorbeeldobjecten van één entiteitstype — het startpunt van de lus voor het schrijven van schema's. Taal staat standaard op auto en wordt afgeleid uit de woorden van je eigen verzoek.
SchemaGenerate SchemaGenereer en bewaar automatisch een JSON-schema — elk invoeritem is één sample van hetzelfde entiteitstype: de vereniging van alle velden, nullable waar een veld in sommige samples ontbreekt, echte waargenomen waarden als voorbeelden. Met de optie Taal bepaal je in welke taal het schema zichzelf beschrijft.
RecordList RecordsBevraag verrijkingsrecords met filters op type en succes. Gepagineerde resultaten.
RecordGet RecordHaal een specifiek enrichment-resultaat op via ID met volledige gestructureerde uitvoer.
RecordSync Records to DatabaseStuur een opgeslagen (of getransformeerde) verrijkingsoutput naar de Database Sync van het bijbehorende schema — opnieuw gevalideerd tegen het gepubliceerde contract en daarna door de toelatingspoort geleid.
FusionMerge ResultsFuseer resultaten van meerdere enrichment-records samen met optionele LLM-arbitrage.
AttachmentAdd AttachmentUpload één of meer binaire bestanden van het invoeritem (één enkele multipart-request) en geef één item per bijlage-ID terug.
AttachmentDelete AttachmentVerwijder een bijlage op ID — een handige opschoonstap na de verrijking.
Database SyncList Database SyncsToon de database syncs die op een schema geregistreerd zijn, met het aantal openstaande delta's.
Database SyncFetch DeltasHaal het volgende FIFO-venster met database-delta's op (SQL + JSON), en lease ze optioneel voor bevestiging.
Database SyncAcknowledge DeltasBevestig toegepaste delta's tot aan een ID — geeft de lease vrij en verwijdert, afhankelijk van de sync-opties, geleverde kopieën.
ConfigurationGet OptionsHaal beschikbare modellen, talen, strategieën en abonnementslimieten op voor dynamische configuratie.

Trigger-node

Het pakket bevat ook een aparte Entity Enricher Trigger-node — een webhook-trigger die een workflow start bij elk platform-event en zijn abonnement automatisch registreert. De Event-dropdown wordt live vanuit je account geladen, dus elk event dat het platform uitstuurt is beschikbaar zonder de node bij te werken:

Verrijkingsrecords— record.created wordt geactiveerd bij elke voltooide verrijking (met of zonder Database Sync). Je kunt dit optioneel beperken tot één schema. Een run die de toelatingscontrole van een Database Sync niet haalde, komt binnen met database.saved = false en de lijst met ontbrekende verplichte velden.
Accounts, facturering en credits— member.*, subscription.*, credits.* — een deelnameverzoek, een rolwijziging, een plan-upgrade, een creditaankoop of een laag/uitgeput saldo. Elk "updated"-event bevat een changes-map die precies aangeeft welk attribuut is gewijzigd.
Jobs en schema's— job.completed / job.failed voor elke LLM-job — verrijking, batch, benchmark, sample of schemageneratie — en schema.updated wanneer een schema wordt gepubliceerd; dat is het signaal om op te wachten voordat je een nieuwe vorm uitleest. Een mislukte job bevat naast het bericht een getypeerde error_code.
AI-providers— provider.failed wanneer een aanroep naar een AI-provider na de nieuwe pogingen mislukt aan de kant van de provider — rate limit, time-out, uitgefaseerd model, account zonder credits — waarbij data.code aangeeft welke; provider.threshold wanneer het account achter een providersleutel zonder credits komt te zitten, eenmaal per sleutel, waarbij key_source aangeeft of het je eigen sleutel is of de gedeelde.
Database-delta's beschikbaar— Wordt geactiveerd zodra er nieuwe SQL-delta's klaarstaan voor een database sync. Met "Fetch Deltas on Fire" ingeschakeld haalt de node de openstaande delta's op en least ze, en geeft één item per delta door aan een volgende Acknowledge Deltas-stap. Een database die door meerdere schema's wordt gevoed, stuurt per schema een melding — elk schema stuurt zijn eigen workflow aan — dus kies naar welk gekoppeld schema deze trigger luistert.

Elke aflevering wordt ondertekend: een X-EE-Signature-header bevat een HMAC-SHA256 van de body met tijdstempel, en X-EE-Delivery blijft gelijk bij nieuwe pogingen, zodat je het als idempotentiesleutel kunt gebruiken. Mislukte afleveringen worden binnen een half uur drie keer opnieuw geprobeerd. Je kunt endpoints ook handmatig registreren — zonder connector — onder Instellingen › Webhooks, waar een afleverlog elke poging toont en je een aflevering opnieuw kunt versturen.

  1. 1De events waarop dit endpoint is geabonneerd
  2. 2De sleutel achter X-EE-Signature
  3. 3Eén rij per poging, met status en latency
De regel wordt weggeschreven vóór de eerste POST, zodat het logboek een audittrail blijft, zelfs als er nooit iets bij je consumer aankomt — en een endpoint dat tien leveringen op rij mislukt, wordt uitgeschakeld in plaats van in de wachtrij te blijven staan voor een URL waar niemand luistert.

Samen met de Database Sync-bewerkingen houdt de trigger een externe database geconvergeerd vanuit alleen n8n — zie de Database Sync-documentatie.

  1. 1Het venster dat de trigger bewaakt
  2. 2Terug naar de verrijking die de delta heeft opgeleverd
  3. 3Het statement dat je database toepast, met revisiebewaking
Wat de trigger aankondigt en Fetch Deltas in behandeling neemt: geordende rijen, elk met het exacte statement dat moet worden toegepast en de verrijking waar het vandaan komt.

Enrichment van één entity

De eenvoudigste workflow: activeer bij nieuwe gegevens, verrijk één entiteit en stuur het resultaat naar je bestemming. De node wacht tot de volledige verrijking is voltooid voordat de gestructureerde output verder wordt doorgegeven.

Voorbeeldworkflow — verrijking van één entiteit:

Node-configuratie — bewerking Enrich Entity:

Configuratie

De standaardbewerkingen Enrich Entity en Batch Enrich tonen alleen het essentiële: schema, bestand uploaden, talen en webzoekopdracht. Entity Enricher draait automatisch met het beste model van je organization — je vastgezette standaardmodel of het model met de hoogste benchmarkscore — en kiest de verrijkingsstrategie op basis van je schema. De bewerkingen Enrich Entity Advanced en Batch Enrich Advanced tonen de volledige set opties hieronder.

Selecteer een schema uit het dynamische dropdownmenu, kies een of meer modellen en geef entiteitsgegevens op als sleutel-waardevelden. De node vult automatisch de zoeksleutelvelden in op basis van het geselecteerde schema.

Optionele instellingen omvatten strategie (single-pass of multi-expertise), talen voor meertalige uitvoer, classificatiemodel voor verificatie van het entiteitstype, arbitragemodel voor conflictoplossing tussen meerdere modellen, en response-schema / strikte gestructureerde uitvoer-schakelaars die schemaconforme uitvoer afdwingen op geschikte modellen.

Om brondocumenten in de enrichment te voeden, schakel je Upload Input Binary Files in: de node uploadt de binaire bestanden van het input-item als attachments in één enkele request (allemaal, of alleen die genoemd in Binary Fields to Upload) en ruimt ze, met Delete Uploaded Attachments After Enrichment (standaard aan), op zodra de enrichment klaar is — geen aparte Add Attachment / Delete Attachment stappen nodig. Je kunt ook een Attachment IDs-veld opgeven (door komma's gescheiden UUID's van eerdere Add Attachment-aanroepen) om eenmaal geüploade documenten in veel enrichments te hergebruiken; beide bronnen kunnen worden gecombineerd. Ook beschikbaar op Batch Enrich, waar bestanden uit alle input-items worden verzameld en op elke entity in de job worden toegepast. Als er een Edit Fields-node tussen de bestandsbron en de enrich-node staat, zet dan de schakelaar Include Other Input Fields aan — anders verwijdert die de binaire data.

Batchverrijking

Verwerk alle invoeritems als één batch. Ideaal voor het verrijken van lijsten uit spreadsheets, databases of API-antwoorden. Alle entiteiten worden parallel verwerkt met snelheidslimieten per provider.

Node-configuratie — bewerking Batch Enrich:

Hoe de batchmodus werkt

  1. Items verzamelen — De node verzamelt alle invoeritems van de vorige node (bijv. rijen uit een spreadsheet).
  2. Batchtaak starten — Alle entiteiten worden ingediend via POST /api/batch/start en parallel verwerkt.
  3. Voortgang streamen — De node verwerkt de SSE-stream totdat alle entiteiten klaar zijn of de time-out wordt bereikt.
  4. Resultaten uitvoeren — Eén output-item per entiteit met de verrijkte gestructureerde data, klaar voor verdere verwerking.

Belangrijkste functies

Eenvoudige en geavanceerde bewerkingen

De standaardbewerkingen Enrich Entity en Batch Enrich tonen alleen schema, bestand uploaden, talen en webzoekopdracht — het beste model en de beste strategie worden automatisch gekozen. Met de geavanceerde bewerkingen krijg je volledige controle over modellen, fusion, strategie en gestructureerde output.

Dynamische dropdowns

De schema-, model-, taal- en strategiekiezers halen opties op uit je Entity Enricher-instantie tijdens het configureren.

SSE-streaming

Verrijkingsbewerkingen verbruiken de SSE-stream in realtime en wachten op voltooiing voordat ze resultaten aan de volgende node doorgeven.

Automatisch doorgaan

Wanneer de pre-flight-classificatie een mismatch detecteert, gaat de connector automatisch verder (n8n-workflows zijn niet-interactief).

Configureerbare time-out

Standaardtime-out van 300 seconden per enrichment-aanroep, per node aanpasbaar voor grote schema's of trage modellen.

Ondersteuning voor meerdere modellen

Selecteer meerdere modellen per enrichment. Wanneer 2+ modellen worden gebruikt, worden de resultaten automatisch samengevoegd.

Uitvoer standaard opschonen

Standaard bevat de uitvoer alleen de verrijkte gegevensvelden. Schakel "Verrijkingsmetadata opnemen" in om kosten, tokens, fusiedetails en record-ID's toe te voegen.

Uitvoer per model

Geef optioneel individuele modelresultaten naast het gefuseerde resultaat weer voor vergelijking verderop in het proces.

Inzicht in planlimieten

Dropdowns voor model en taal tonen de planlimieten wanneer deze zijn ingesteld. HTTP 402-fouten door quotahandhaving worden weergegeven als duidelijke, bruikbare berichten met limietdetails. De metadata-output bevat de huidige planlimieten voor downstream-routing.

Gebruik het vanuit een AI-agent, of begin met een voorbeeld

Een AI Agent-tool

De Entity Enricher-node kan als tool worden gekoppeld aan een n8n AI Agent, zodat een agent zelf bepaalt wanneer die midden in een gesprek een entity verrijkt of een schema ophaalt. De trigger-node wordt bewust niet zo aangeboden — een trigger start een workflow, het is niets dat een agent aanroept.

Zes importeerbare workflows

Het pakket bevat kant-en-klare workflowbestanden — enkele enrichment, batch, document naar enrichment, afbeelding naar sample naar schema, samples naar schema, en het leegtrekken van een deltafeed naar PostgreSQL. Importeer er een en zet je eigen credential erin in plaats van alles zelf op te bouwen.

Workflow-ideeën

Veelvoorkomende patronen voor het bouwen van enrichment-pijplijnen met n8n:

CRM-verrijking— Start bij nieuwe HubSpot-/Salesforce-contacten, verrijk met bedrijfsgegevens en werk het CRM-record bij.
Spreadsheet-pipeline— Lees entiteiten uit Google Sheets, verrijk in batch en schrijf de resultaten terug naar een nieuw blad.
Waterfall-enrichment— Koppel meerdere verrijkingsstappen aan elkaar met voorwaardelijke logica — gebruik eerst een snel model en verrijk mislukkingen opnieuw met een capabeler model.
Geplande vernieuwing— Voer uit volgens een cron-schema om verouderde records opnieuw te verrijken met de nieuwste AI-modellen.
Webhook-gestuurd— Stel een webhook-endpoint beschikbaar dat entiteitsgegevens accepteert, deze verrijkt en het resultaat synchroon retourneert.

Volgende stappen