n8n-Connector – Entity Enricher Dokumentation

n8n-Connector

Der Entity-Enricher-Community-Node für n8n ermöglicht es Ihnen, automatisierte Anreicherungs-Pipelines mit einem visuellen Drag-and-Drop-Editor zu erstellen. Verbinden Sie sich mit über 400 Apps, ohne Code zu schreiben.

Installation

Installieren Sie den Community-Node in Ihrer n8n-Instanz:

npm install n8n-nodes-entity-enricher

Oder installieren Sie über die n8n-Oberfläche: Gehen Sie zu Einstellungen → Community Nodes und suchen Sie nach n8n-nodes-entity-enricher.

Voraussetzungen

API-SchlüsselErstellen Sie einen Organisationszugriffsschlüssel in Entity Enricher. Siehe die API-Schlüssel-Dokumentation für Details. Das Schlüsselformat ist ent_XXXXXXXXXXXX.
Basis-URLDie URL Ihrer Entity Enricher-Instanz (z. B. https://entityenricher.ai oder Ihre selbst gehostete URL).
Einrichtung der AnmeldedatenErstellen Sie in n8n einen Entity Enricher API-Zugang mit Ihrem API-Key und Ihrer Basis-URL. Alle Nodes verwenden diesen Zugang. Ein Organisations-Zugangsschlüssel funktioniert unabhängig von jedem Benutzerkonto — die Empfehlung für dauerhafte Service-zu-Service-Workflows.
OAuth2 (Alternative)Möchten Sie sich lieber mit Ihrem Konto verbinden? Erstellen Sie stattdessen einen Entity Enricher OAuth2 API-Zugang: Kopieren Sie die OAuth-Redirect-URL, die n8n anzeigt, registrieren Sie damit einen OAuth-Client in Entity Enricher unter API Keys → Verbundene Apps → OAuth-Clients (Besitzer-Rolle), fügen Sie die Client-ID in n8n ein und klicken Sie auf Mein Konto verbinden. Die Verbindung handelt mit Ihrer eigenen Rolle und ist jederzeit unter Verbundene Apps widerrufbar. Wählen Sie den Zugang am Node über dessen Parameter Authentifizierung aus.

Verfügbare Operationen

Der Connector stellt 18 Operationen in 7 Ressourcenkategorien bereit:

RessourceVorgangBeschreibung
EnrichmentEnrich EntityReichern Sie eine einzelne Entity an – wählen Sie einfach ein Schema; das beste Modell und die beste Strategie Ihrer Organisation werden automatisch ausgewählt. Streamt Ergebnisse über SSE mit Fortschrittsanzeige in Echtzeit.
EnrichmentEnrich Entity AdvancedReichern Sie eine einzelne Entity mit voller Kontrolle über Modelle, Fusion, Strategie, Klassifizierung und strukturierte Ausgabe an.
EnrichmentBatch EnrichReichern Sie alle Eingabeelemente als einen einzigen Batch mit dem automatischen Modell und der automatischen Strategie an. Parallele Verarbeitung mit Fortschrittsverfolgung pro Entity.
EnrichmentBatch Enrich AdvancedReichern Sie alle Eingabeelemente als einen einzigen Batch mit dem vollständigen Parametersatz an.
SchemaList SchemasVerfügbare gespeicherte Schemas zur Auswahl in Anreicherungs-Workflows auflisten.
SchemaGet Schema DetailsVollständigen Schema-Inhalt mit extrahierten Schlüsseleigenschaften für ein bestimmtes Schema abrufen.
SchemaGenerate SampleErzeugen Sie 1..N realistische JSON-Beispielobjekte eines Entitätstyps in einem einzigen Job — der Einstiegspunkt in den Schema-Erstellungszyklus. Die Sprache steht standardmäßig auf auto und wird aus den Worten Ihrer eigenen Anfrage abgeleitet.
SchemaGenerate SchemaErzeugen und speichern Sie automatisch ein JSON-Schema — jedes Eingabeelement ist ein Sample desselben Entitätstyps: Vereinigung der Felder, nullable dort, wo ein Feld in manchen Samples fehlt, tatsächlich beobachtete Werte als Beispiele. Eine Sprachoption legt fest, in welcher Sprache sich das Schema selbst beschreibt.
RecordList RecordsFragen Sie Anreicherungs-Records mit Typ- und Erfolgsfiltern ab. Paginierte Ergebnisse.
RecordGet RecordEin bestimmtes Enrichment-Ergebnis anhand der ID mit vollständiger strukturierter Ausgabe abrufen.
RecordSync Records to DatabaseSenden Sie ein gespeichertes (oder transformiertes) Anreicherungsergebnis an die Datenbanksynchronisierung seines Schemas – erneut gegen den veröffentlichten Vertrag validiert und anschließend durch das Aufnahme-Gate geführt.
FusionMerge ResultsErgebnisse aus mehreren Enrichment-Records fusionieren – mit optionaler LLM-Arbitrierung.
AttachmentAdd AttachmentLaden Sie eine oder mehrere Binärdateien aus dem Eingabe-Element hoch (einzelne Multipart-Anfrage) und geben Sie ein Element pro Anhang-ID zurück.
AttachmentDelete AttachmentEinen Anhang anhand der ID löschen – ein praktischer Aufräumschritt nach der Anreicherung.
Database SyncList Database SyncsDie für ein Schema registrierten Database Syncs auflisten, mit der Anzahl ausstehender Deltas.
Database SyncFetch DeltasDas nächste FIFO-Fenster von Datenbank-Deltas (SQL + JSON) abrufen, optional zur Bestätigung geleast.
Database SyncAcknowledge DeltasAngewendete Deltas bis zu einer ID bestätigen – gibt den Lease frei und entfernt gemäß den Sync-Optionen zugestellte Kopien.
ConfigurationGet OptionsRufen Sie verfügbare Modelle, Sprachen, Strategien und Tarifgrenzen für die dynamische Konfiguration ab.

Trigger-Knoten

Das Paket enthält außerdem einen separaten Entity Enricher Trigger-Knoten – einen Webhook-Trigger, der einen Workflow bei Schema-Ereignissen startet und sein Abonnement automatisch registriert:

AnreicherungsergebnisWird bei jeder abgeschlossenen Anreicherung des ausgewählten Schemas ausgelöst (mit oder ohne Database Sync).
Für Datenbankspeicherung abgelehntWird ausgelöst, wenn eine Anreicherung das Aufnahme-Gate eines Database Sync nicht besteht – die Payload gibt an, welche erforderlichen Felder fehlten.
Datenbank-Deltas verfügbarWird ausgelöst, wenn neue SQL-Deltas für einen Database Sync bereitstehen. Ist „Fetch Deltas on Fire“ aktiviert, ruft der Node die ausstehenden Deltas ab und reserviert sie, wobei er pro Delta ein Item für einen nachgelagerten Acknowledge-Deltas-Schritt ausgibt. Eine Datenbank, die von mehreren Schemas gespeist wird, benachrichtigt pro Schema — jedes steuert seinen eigenen Workflow —, wählen Sie also aus, auf welches verknüpfte Schema dieser Trigger hört.

Zusammen mit den Database-Sync-Operationen hält der Trigger eine externe Datenbank allein aus n8n heraus konvergent – siehe die Database Sync-Dokumentation.

Anreicherung einzelner Entitäten

Der einfachste Workflow: bei neuen Daten auslösen, eine einzelne Entität anreichern und das Ergebnis an Ihr Ziel übertragen. Der Knoten wartet, bis die vollständige Anreicherung abgeschlossen ist, bevor er die strukturierte Ausgabe weitergibt.

Beispiel-Workflow — Anreicherung einer einzelnen Entität:

Node-Konfiguration – Operation „Enrich Entity“:

Entity-Enricher-Node-Konfiguration für Einzelanreicherung

Konfiguration

Die Standardvorgänge Entity anreichern und Batch anreichern zeigen nur das Wesentliche: Schema, Datei-Upload, Sprachen und Websuche. Entity Enricher läuft automatisch mit dem besten Modell Ihrer Organisation – Ihrem angehefteten Standard oder dem Modell mit der höchsten Benchmark-Bewertung – und wählt die Anreicherungsstrategie anhand Ihres Schemas aus. Die Vorgänge Entity anreichern (erweitert) und Batch anreichern (erweitert) stellen den vollständigen Satz der unten aufgeführten Optionen bereit.

Wählen Sie ein Schema aus dem dynamischen Dropdown, wählen Sie ein oder mehrere Modelle und geben Sie Entitätsdaten als Schlüssel-Wert-Felder an. Der Node füllt die Suchschlüsselfelder automatisch basierend auf dem ausgewählten Schema.

Zu den optionalen Einstellungen gehören Strategie (Single-Pass oder Multi-Expertise), Sprachen für mehrsprachige Ausgabe, Classification-Modell zur Verifizierung des Entity-Typs, Arbitration-Modell zur Konfliktlösung zwischen mehreren Modellen sowie Antwort-Schema- / strikte strukturierte Ausgabe-Schalter, die eine schemakonforme Ausgabe auf fähigen Modellen erzwingen.

Um Quelldokumente in die Anreicherung einzuspeisen, aktivieren Sie Eingabe-Binärdateien hochladen: Der Node lädt die Binärdateien des Eingabe-Items als Anhänge in einer einzigen Anfrage hoch (entweder alle oder nur die unter Hochzuladende Binärfelder genannten) und räumt sie mit Hochgeladene Anhänge nach der Anreicherung löschen (standardmäßig aktiviert) nach Abschluss der Anreicherung wieder auf — separate Schritte zum Anhang hinzufügen / Anhang löschen sind nicht erforderlich. Alternativ können Sie ein Feld Anhang-IDs angeben (kommagetrennte UUIDs aus vorherigen Aufrufen von „Anhang hinzufügen"), um einmal hochgeladene Dokumente über viele Anreicherungen hinweg wiederzuverwenden; beide Quellen lassen sich kombinieren. Ebenfalls verfügbar bei der Batch-Anreicherung, wo Dateien aus allen Eingabe-Items gesammelt werden und für jede Entität im Auftrag gelten. Wenn ein „Edit Fields"-Node zwischen der Dateiquelle und dem Anreicherungs-Node liegt, aktivieren Sie dessen Schalter Weitere Eingabefelder einbeziehen — andernfalls entfernt er die Binärdaten.

Batch-Anreicherung

Verarbeiten Sie alle Eingabeelemente als einen einzigen Batch. Ideal zum Anreichern von Listen aus Tabellen, Datenbanken oder API-Antworten. Alle Entitäten werden parallel mit anbieterspezifischer Ratenbegrenzung verarbeitet.

Node-Konfiguration – Operation „Batch Enrich“:

Entity-Enricher-Node-Konfiguration für Batch-Anreicherung

So funktioniert der Batch-Modus

  1. Elemente sammeln – Der Knoten sammelt alle Eingabeelemente vom vorherigen Knoten (z. B. Zeilen aus einer Tabelle).
  2. Batch-Job starten — Alle Entitäten werden über POST /api/batch/start übermittelt und parallel verarbeitet.
  3. Fortschritt streamen — Der Node verarbeitet den SSE-Stream, bis alle Entitäten abgeschlossen sind oder das Zeitlimit erreicht wird.
  4. Ausgabeergebnisse — Ein Ausgabeelement pro Entität mit den angereicherten strukturierten Daten, bereit für die Weiterverarbeitung.

Wichtige Funktionen

Einfache & erweiterte Vorgänge

Die Standardvorgänge „Entity anreichern“ und „Batch anreichern“ zeigen nur Schema, Datei-Upload, Sprachen und Websuche – das beste Modell und die beste Strategie werden automatisch ausgewählt. Die erweiterten Vorgänge geben Ihnen volle Kontrolle über Modelle, Fusion, Strategie und strukturierte Ausgabe.

Dynamische Dropdowns

Die Auswahlfelder für Schema, Modell, Sprache und Strategie rufen die Optionen zum Konfigurationszeitpunkt aus Ihrer Entity Enricher-Instanz ab.

SSE-Streaming

Anreicherungsvorgänge konsumieren den SSE-Stream in Echtzeit und warten auf den Abschluss, bevor sie Ergebnisse an den nächsten Node zurückgeben.

Automatisch fortsetzen

Wenn die Pre-Flight-Klassifizierung eine Nichtübereinstimmung erkennt, fährt der Connector automatisch fort (n8n-Workflows sind nicht interaktiv).

Konfigurierbares Timeout

Standard-Timeout von 300 Sekunden pro Anreicherungsaufruf, pro Node anpassbar für große Schemas oder langsame Modelle.

Multi-Modell-Unterstützung

Wählen Sie mehrere Modelle pro Anreicherung. Wenn 2 oder mehr Modelle verwendet werden, werden die Ergebnisse automatisch fusioniert.

Ausgabe standardmäßig bereinigen

Standardmäßig enthält die Ausgabe nur die angereicherten Datenfelder. Schalten Sie „Anreicherungs-Metadaten einschließen“ ein, um Kosten, Tokens, Fusion-Details und Record-IDs hinzuzufügen.

Ausgabe pro Modell

Optional die einzelnen Modellergebnisse zusätzlich zum fusionierten Ergebnis für einen nachgelagerten Vergleich ausgeben.

Kenntnis der Planlimits

Modell- und Sprach-Dropdowns zeigen Tariflimits an, sofern konfiguriert. HTTP-402-Fehler aus der Kontingentdurchsetzung werden als klare, umsetzbare Meldungen mit Limitdetails dargestellt. Die Metadatenausgabe enthält die aktuellen Tariflimits für das nachgelagerte Routing.

Nutzen Sie es über einen KI-Agenten oder starten Sie mit einem Beispiel

Ein KI-Agenten-Tool

Der Entity Enricher-Node lässt sich einem n8n-AI Agent als Tool zuordnen, sodass ein Agent selbst entscheidet, wann er mitten im Gespräch eine Entität anreichert oder ein Schema abruft. Der Trigger-Node wird bewusst nicht auf diese Weise angeboten – ein Trigger startet einen Workflow, er ist nichts, was ein Agent aufruft.

Sechs importierbare Workflows

Das Paket enthält fertige Workflow-Dateien – einzelne Anreicherung, Batch, Dokument zu Anreicherung, Bild zu Sample zu Schema, Samples zu Schema und das Leeren eines Delta-Feeds nach PostgreSQL. Importieren Sie eine davon und tauschen Sie Ihre eigenen Zugangsdaten ein, statt sie von Grund auf zu verdrahten.

Workflow-Ideen

Gängige Muster zum Erstellen von Anreicherungs-Pipelines mit n8n:

CRM-EnrichmentBei neuen HubSpot-/Salesforce-Kontakten auslösen, mit Unternehmensdaten anreichern, den CRM-Datensatz aktualisieren.
Tabellen-PipelineEntitäten aus Google Sheets lesen, im Batch anreichern und die Ergebnisse in ein neues Sheet zurückschreiben.
Waterfall-EnrichmentVerketten Sie mehrere Anreicherungsschritte mit bedingter Logik — verwenden Sie zuerst ein schnelles Modell und reichern Sie Fehlschläge mit einem leistungsfähigeren Modell erneut an.
Geplante AktualisierungNach einem Cron-Zeitplan ausführen, um veraltete Datensätze mit den neuesten KI-Modellen neu anzureichern.
Webhook-gesteuertStellen Sie einen Webhook-Endpunkt bereit, der Entitätsdaten annimmt, sie anreichert und das Ergebnis synchron zurückgibt.

Nächste Schritte