n8n用のEntity Enricherコミュニティノードを使用すると、ビジュアルなドラッグ&ドロップエディタで自動化されたエンリッチメントパイプラインを構築できます。コードを書くことなく、400以上のアプリに接続できます。
お使いの n8n インスタンスにコミュニティノードをインストールします:
npm install n8n-nodes-entity-enricher
または n8n の UI からインストール:Settings → Community Nodes に移動し、n8n-nodes-entity-enricher を検索します。
ent_XXXXXXXXXXXXです。https://entityenricher.ai、またはセルフホストのURL)。コネクタは、6つのリソースカテゴリにわたって10個の操作を提供します:
| リソース | 操作 | 説明 |
|---|---|---|
| Enrichment | Enrich Entity | 単一の entity を 1 つ以上の AI model で enrichment します。SSE 経由でリアルタイムの進捗とともに結果をストリーミングします。 |
| Enrichment | Batch Enrich | すべての入力項目を単一の batch として enrichment します。entity ごとの進捗追跡を伴う並列処理です。 |
| Schema | List Schemas | エンリッチメントワークフローで選択できるよう、保存済みのスキーマを一覧表示します。 |
| Schema | Get Schema Details | 特定のschemaについて、抽出された主要なプロパティを含む完全なschemaコンテンツを取得します。 |
| Record | List Records | タイプと成功のフィルターでエンリッチメントレコードを照会します。結果はページ分割されます。 |
| Record | Get Record | 完全な構造化出力を含む特定のenrichment結果をIDで取得します。 |
| Fusion | Merge Results | 複数のエンリッチメントレコードの結果を、オプションの LLM 調停でフュージョンします。 |
| Attachment | Add Attachment | 入力項目からバイナリプロパティ(multipart)をアップロードし、そのアタッチメント ID を返します。 |
| Attachment | Delete Attachment | IDでattachmentを削除します。enrichment後の便利なクリーンアップ手順です。 |
| Configuration | Get Options | 動的な設定のために、利用可能なmodel、言語、戦略、プラン上限を取得します。 |
最もシンプルなワークフローです。新しいデータをトリガーにして単一の entity を enrichment し、その結果を出力先にプッシュします。このノードは、構造化出力を下流に渡す前に、enrichment 全体が完了するのを待ちます。
ワークフローの例 — 単一エンティティのエンリッチメント:
ノード設定 — Enrich Entity操作:

動的ドロップダウンからスキーマを選択し、1つ以上のモデルを選択して、エンティティデータをキーと値のフィールドとして入力します。ノードは選択したスキーマに基づいて検索キーフィールドを自動的に入力します。
任意の設定には、戦略(シングルパスまたはマルチ専門領域)、多言語出力のための言語、エンティティ型検証のための分類モデル、マルチモデルの競合解決のためのアービトレーションモデル、そして対応可能なモデルでスキーマ準拠の出力を強制するレスポンススキーマ/厳密な構造化出力のトグルが含まれます。
Attachment IDフィールド(以前のAdd Attachment呼び出しで取得したUUIDをカンマ区切りで指定)を入力すると、ソースドキュメントをenrichmentに取り込めます。Batch Enrichでも利用可能です。
すべての入力項目を単一のバッチとして処理します。スプレッドシート、データベース、API レスポンスからのリストのエンリッチメントに最適です。すべてのエンティティは、プロバイダーごとのレート制限のもとで並列処理されます。
ノード設定 — Batch Enrich操作:

POST /api/batch/startで送信され、並列で処理されます。スキーマ、モデル、言語、戦略のセレクターは、設定時にお使いのEntity Enricherインスタンスから選択肢を取得します。
エンリッチメント操作はSSEストリームをリアルタイムで消費し、完了を待ってから次のノードに結果を返します。
プリフライトの classification が不一致を検出した場合、コネクタは自動的に処理を続行します(n8n ワークフローは非対話型です)。
エンリッチメント呼び出しごとのデフォルトのタイムアウトは300秒で、大きなスキーマや低速なモデルに対応してノードごとに調整できます。
エンリッチメントごとに複数のモデルを選択できます。2つ以上のモデルを使用すると、結果は自動的にフュージョンされます。
デフォルトでは、出力にはenrichment済みのデータフィールドのみが含まれます。「Enrichmentメタデータを含める」をオンにすると、コスト、トークン、fusionの詳細、recordのIDが追加されます。
下流での比較のために、フュージョン結果と併せて個々のモデルの結果を任意で出力します。
設定されている場合、モデルと言語のドロップダウンにはプラン制限が表示されます。クォータ適用による HTTP 402 エラーは、制限の詳細を含む明確で実行可能なメッセージとして表示されます。メタデータ出力には、下流のルーティング用に現在のプラン制限が含まれます。
n8nでエンリッチメントパイプラインを構築する際の一般的なパターン: