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.
  1. 1Der Name, der in Connected Apps angezeigt wird
  2. 2Die OAuth-Redirect-URL von n8n, exakt kopiert
  3. 3Gibt die Client-ID zurück, die Sie in n8n einfügen
Ein Client kann nachträglich nicht bearbeitet werden – seine Redirect-URL wird bei der Erstellung festgelegt. Eine zweite n8n-Instanz erhält daher einen eigenen Client, und wird ein Client gelöscht, werden sofort alle darüber hergestellten Verbindungen widerrufen.

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-Node — einen Webhook-Trigger, der bei jedem Plattformereignis einen Workflow startet und sein Abonnement automatisch registriert. Sein Event-Dropdown wird live aus Ihrem Konto geladen, sodass jedes von der Plattform ausgegebene Ereignis verfügbar ist, ohne den Node zu aktualisieren:

Anreicherungsdatensätzerecord.created wird bei jeder abgeschlossenen Anreicherung ausgelöst (mit oder ohne Database Sync). Optional können Sie es auf ein einzelnes Schema eingrenzen. Ein Lauf, der die Zulassungsprüfung eines Database Sync nicht bestanden hat, kommt mit database.saved = false und der Liste der fehlenden Pflichtfelder an.
Konten, Abrechnung und Creditsmember.*, subscription.*, credits.* — eine Beitrittsanfrage, eine Rollenänderung, ein Plan-Upgrade, ein Credit-Kauf oder ein niedriger/aufgebrauchter Kontostand. Jedes „updated"-Ereignis enthält eine changes-Map, die genau angibt, welches Attribut sich geändert hat.
Jobs und Schemasjob.completed / job.failed für jeden LLM-Job – Anreicherung, Batch, Benchmark, Beispiel- oder Schema-Generierung – und schema.updated, wenn ein Schema veröffentlicht wird; das ist das Signal, auf das Sie warten sollten, bevor Sie eine neue Struktur auslesen. Ein fehlgeschlagener Job enthält neben der Meldung einen typisierten error_code.
KI-Anbieterprovider.failed, wenn ein Aufruf an einen KI-Anbieter nach den Wiederholungsversuchen auf Anbieterseite fehlschlägt – Ratenbegrenzung, Zeitüberschreitung, eingestelltes Modell, Konto ohne Credits – wobei data.code angibt, welcher Fall vorliegt; provider.threshold, wenn dem Konto hinter einem Anbieterschlüssel die Credits ausgehen, einmal pro Schlüssel, wobei key_source angibt, ob es sich um Ihren eigenen oder den gemeinsamen Schlüssel handelt.
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.

Jede Zustellung ist signiert: Ein X-EE-Signature-Header enthält einen HMAC-SHA256 des mit Zeitstempel versehenen Bodys, und X-EE-Delivery bleibt über Wiederholungen hinweg stabil, sodass Sie den Wert als Idempotenzschlüssel verwenden können. Fehlgeschlagene Zustellungen werden innerhalb einer halben Stunde dreimal wiederholt. Sie können Endpunkte auch von Hand registrieren – ganz ohne Connector – unter Einstellungen › Webhooks, wo ein Zustellungsprotokoll jeden Versuch anzeigt und das erneute Senden ermöglicht.

  1. 1Die Events, die dieser Endpunkt abonniert
  2. 2Der Schlüssel hinter X-EE-Signature
  3. 3Eine Zeile pro Versuch, mit Status und Latenz
Die Zeile wird vor dem ersten POST geschrieben, sodass das Log auch dann ein Audit-Trail ist, wenn bei Ihrem Consumer nie etwas ankommt — und ein Endpunkt, bei dem zehn Zustellungen in Folge fehlschlagen, wird abgeschaltet, statt sich in eine URL zu stauen, an der niemand zuhört.

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

  1. 1Das Zeitfenster, das der Trigger überwacht
  2. 2Zurück zur Anreicherung, die das Delta erzeugt hat
  3. 3Die Anweisung, die Ihre Datenbank anwendet – revisionsgeschützt
Was der Trigger meldet und Fetch Deltas reserviert: geordnete Zeilen, die jeweils die genaue anzuwendende Anweisung und die zugehörige Anreicherung enthalten.

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“:

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“:

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