n8n コネクター - Entity Enricher ドキュメント

n8n コネクター

n8n用のEntity Enricherコミュニティノードを使用すると、ビジュアルなドラッグ&ドロップエディタで自動化されたエンリッチメントパイプラインを構築できます。コードを書くことなく、400以上のアプリに接続できます。

インストール

お使いの n8n インスタンスにコミュニティノードをインストールします:

npm install n8n-nodes-entity-enricher

または n8n の UI からインストール：Settings → Community Nodes に移動し、n8n-nodes-entity-enricher を検索します。

前提条件

APIキー— Entity Enricherでorganizationアクセスキーを作成します。詳細はAPI Keysのドキュメントを参照してください。キーの形式はent_XXXXXXXXXXXXです。
ベース URL— Entity EnricherインスタンスのURL(例:https://entityenricher.ai、またはセルフホストのURL)。
認証情報の設定— n8n で、API キーとベース URL を使用して Entity Enricher API 認証情報を作成します。すべてのノードがこの認証情報を使用します。organization アクセスキーは、いずれのユーザーアカウントからも独立して動作するため、耐久性のあるサービス間ワークフローに推奨されます。
OAuth2（代替）— ご自身のアカウントで接続したいですか？代わりに Entity Enricher OAuth2 API 認証情報を作成します。n8n が表示する OAuth リダイレクト URL をコピーし、それを使って Entity Enricher の API Keys → Connected Apps → OAuth Clients（owner ロール）で OAuth クライアントを登録し、クライアント ID を n8n に貼り付けて、Connect my account をクリックします。この接続はご自身のロールで動作し、Connected Apps からいつでも取り消せます。ノードの Authentication パラメーターでこの認証情報を選択してください。

利用可能な操作

このコネクタは、7つのリソースカテゴリにわたる18の操作を提供します：

リソース操作説明
EnrichmentEnrich Entity単一のエンティティをエンリッチメントします。スキーマを選ぶだけで、組織にとって最適なモデルと戦略が自動的に選択されます。結果は SSE でストリーミングされ、進捗をリアルタイムに確認できます。
EnrichmentEnrich Entity Advancedモデル、フュージョン、戦略、分類、構造化出力を完全に制御しながら、単一のエンティティをエンリッチメントします。
EnrichmentBatch Enrichすべての入力項目を単一のバッチとして、自動選択のモデルと戦略でエンリッチメントします。エンティティごとの進捗を追跡しながら並列処理します。
EnrichmentBatch Enrich Advancedすべての入力項目を、完全なパラメータセットを使って単一のバッチとしてエンリッチメントします。
SchemaList Schemasエンリッチメントワークフローで選択できるよう、保存済みのスキーマを一覧表示します。
SchemaGet Schema Details特定のschemaについて、抽出された主要なプロパティを含む完全なschemaコンテンツを取得します。
SchemaGenerate Sample1 つのエンティティタイプについて、現実的なサンプル JSON オブジェクトを 1〜N 件、単一のジョブで生成します。スキーマ作成ループの入口となる機能です。言語の既定は auto で、リクエストの文面から推測されます。
SchemaGenerate SchemaJSON スキーマを生成して自動保存します。入力された各アイテムは同じエンティティタイプのサンプルとして扱われ、フィールドは和集合となり、一部のサンプルに存在しないフィールドは nullable になり、実際に観測された値が例として使われます。Language オプションでは、スキーマが自身を記述する言語を指定します。
RecordList Recordsタイプと成功のフィルターでエンリッチメントレコードを照会します。結果はページ分割されます。
RecordGet Record完全な構造化出力を含む特定のenrichment結果をIDで取得します。
RecordSync Records to Database保存された（または変換された）エンリッチメント結果を、そのスキーマのデータベース同期に送信します。公開済みの契約に対して再検証されたうえで、受け入れゲートを通過します。
FusionMerge Results複数のエンリッチメントレコードの結果を、オプションの LLM 調停でフュージョンします。
AttachmentAdd Attachment入力アイテムから1つ以上のバイナリファイルをアップロードし（単一のマルチパートリクエスト）、attachment IDごとに1つのアイテムを返します。
AttachmentDelete AttachmentIDでattachmentを削除します。enrichment後の便利なクリーンアップ手順です。
Database SyncList Database Syncsスキーマに登録されたデータベース同期を、保留中のデルタ数とともに一覧表示します。
Database SyncFetch Deltasデータベースデルタ(SQL + JSON)の次のFIFOウィンドウを取得し、必要に応じて確認応答用にリースします。
Database SyncAcknowledge Deltas指定したIDまでの適用済みデルタを確認応答します。リースを解放し、同期オプションに応じて配信済みのコピーを削除します。
ConfigurationGet Options動的な設定のために、利用可能なmodel、言語、戦略、プラン上限を取得します。

トリガーノード

このパッケージには、別個のEntity Enricher Triggerノードも同梱されています。これは、スキーマイベントでワークフローを開始し、サブスクリプションを自動的に登録するwebhookトリガーです:

エンリッチメント結果— 選択したスキーマのエンリッチメントが完了するたびに(データベース同期の有無にかかわらず)発火します。
データベース保存が拒否されました— エンリッチメントがデータベース同期の受け入れゲートに失敗したときに発火します。ペイロードには、どの必須フィールドが欠落していたかが示されます。
データベースデルタが利用可能です— Database Sync 用の新しい SQL デルタが準備できると発火します。"Fetch Deltas on Fire" を有効にすると、ノードは保留中のデルタを取得してリースし、デルタごとに 1 件のアイテムを出力して後続の Acknowledge Deltas ステップに渡します。複数のスキーマから供給されるデータベースはスキーマごとに通知し、それぞれが独自のワークフローを駆動するため、このトリガーが監視するリンク済みスキーマを選択してください。

Database Sync操作と組み合わせることで、このトリガーはn8nだけで外部データベースを収束した状態に保ちます。Database Sync のドキュメントを参照してください。

単一エンティティエンリッチメント

最もシンプルなワークフローです。新しいデータをトリガーにして単一の entity を enrichment し、その結果を出力先にプッシュします。このノードは、構造化出力を下流に渡す前に、enrichment 全体が完了するのを待ちます。

ワークフローの例 — 単一エンティティのエンリッチメント:

ノード設定 — Enrich Entity操作:

単一エンリッチメント用の Entity Enricher ノード設定

設定

デフォルトの Enrich Entity および Batch Enrich 操作では、必要最小限の項目のみが表示されます。スキーマ、ファイルアップロード、言語、ウェブ検索 です。Entity Enricher は組織にとって最適なモデル（ピン留めしたデフォルト、またはベンチマークスコアが最も高いモデル）で自動的に実行され、スキーマからエンリッチメント戦略を選択します。Enrich Entity Advanced および Batch Enrich Advanced 操作では、以下のすべてのオプションが表示されます。

動的ドロップダウンからスキーマを選択し、1つ以上のモデルを選択して、エンティティデータをキーと値のフィールドとして入力します。ノードは選択したスキーマに基づいて検索キーフィールドを自動的に入力します。

任意の設定には、戦略（シングルパスまたはマルチ専門領域）、多言語出力のための言語、エンティティ型検証のための分類モデル、マルチモデルの競合解決のためのアービトレーションモデル、そして対応可能なモデルでスキーマ準拠の出力を強制するレスポンススキーマ／厳密な構造化出力のトグルが含まれます。

ソース文書をenrichmentに取り込むには、Upload Input Binary Filesを有効にしてください。ノードは入力アイテムのバイナリファイルを単一のリクエストでattachmentとしてアップロードし（すべて、またはBinary Fields to Uploadで指定したものだけ）、Delete Uploaded Attachments After Enrichment（デフォルトでオン）により、enrichmentの完了後にそれらをクリーンアップします。個別のAdd Attachment／Delete Attachmentステップは不要です。あるいは、Attachment IDsフィールド（以前のAdd Attachment呼び出しで得たカンマ区切りのUUID）を指定して、一度アップロードした文書を複数のenrichmentで再利用することもできます。両方のソースを組み合わせることも可能です。Batch Enrichでも利用でき、その場合ファイルはすべての入力アイテムから収集され、ジョブ内のすべてのentityに適用されます。ファイルソースとenrichノードの間にEdit Fieldsノードがある場合は、そのInclude Other Input Fieldsスイッチを有効にしてください。そうしないとバイナリデータが除去されます。

バッチエンリッチメント

すべての入力項目を単一のバッチとして処理します。スプレッドシート、データベース、API レスポンスからのリストのエンリッチメントに最適です。すべてのエンティティは、プロバイダーごとのレート制限のもとで並列処理されます。

ノード設定 — Batch Enrich操作:

バッチエンリッチメント用の Entity Enricher ノード設定

バッチモードの仕組み

  1. アイテムの収集 — ノードが前のノードからすべての入力アイテム（例：スプレッドシートの行）を収集します。
  2. batchジョブを開始 — すべてのentityはPOST /api/batch/startで送信され、並列で処理されます。
  3. 進捗のストリーミング — ノードは、すべてのentityが完了するかタイムアウトに達するまでSSEストリームを消費します。
  4. 結果を出力 — エンティティごとに1つの出力アイテムが、エンリッチされた構造化データとして下流処理向けに準備されます。

主な特徴

シンプルおよびアドバンスト操作

デフォルトの Enrich Entity および Batch Enrich 操作では、スキーマ、ファイルアップロード、言語、ウェブ検索のみが表示され、最適なモデルと戦略は自動的に選択されます。Advanced 操作では、モデル、フュージョン、戦略、構造化出力を完全に制御できます。

動的ドロップダウン

スキーマ、モデル、言語、戦略のセレクターは、設定時にお使いのEntity Enricherインスタンスから選択肢を取得します。

SSEストリーミング

エンリッチメント操作はSSEストリームをリアルタイムで消費し、完了を待ってから次のノードに結果を返します。

自動継続

プリフライトの classification が不一致を検出した場合、コネクタは自動的に処理を続行します（n8n ワークフローは非対話型です）。

設定可能なタイムアウト

エンリッチメント呼び出しごとのデフォルトのタイムアウトは300秒で、大きなスキーマや低速なモデルに対応してノードごとに調整できます。

マルチモデルサポート

エンリッチメントごとに複数のモデルを選択できます。2つ以上のモデルを使用すると、結果は自動的にフュージョンされます。

デフォルトで出力をクリーンにする

デフォルトでは、出力にはenrichment済みのデータフィールドのみが含まれます。「Enrichmentメタデータを含める」をオンにすると、コスト、トークン、fusionの詳細、recordのIDが追加されます。

model ごとの出力

下流での比較のために、フュージョン結果と併せて個々のモデルの結果を任意で出力します。

プラン上限の把握

設定されている場合、モデルと言語のドロップダウンにはプラン制限が表示されます。クォータ適用による HTTP 402 エラーは、制限の詳細を含む明確で実行可能なメッセージとして表示されます。メタデータ出力には、下流のルーティング用に現在のプラン制限が含まれます。

AI エージェントから使う、またはサンプルから始める

AI エージェントツール

Entity Enricher ノードは n8n の AI Agent にツールとして接続できます。これにより、エージェントは会話の途中でエンティティをエンリッチするタイミングやスキーマを取得するタイミングを自ら判断します。トリガーノードは意図的にこの形では提供していません。トリガーはワークフローを開始するものであり、エージェントが呼び出すものではないからです。

インポート可能なワークフローが 6 種類

このパッケージには、すぐに使えるワークフローファイルが同梱されています。単一エンリッチメント、バッチ、ドキュメントからエンリッチメント、画像からサンプル、そしてスキーマへ、サンプルからスキーマ、差分フィードの PostgreSQL への排出です。一から組み立てる代わりに、いずれかをインポートして自分の認証情報に差し替えてください。

ワークフローのアイデア

n8nでエンリッチメントパイプラインを構築する際の一般的なパターン：

CRMエンリッチメント— 新しいHubSpot/Salesforceの連絡先でトリガーし、会社データでエンリッチして、CRMレコードを更新します。
スプレッドシートパイプライン— Google Sheetsからエンティティを読み込み、バッチでエンリッチし、結果を新しいシートに書き戻します。
ウォーターフォール enrichment— 複数の enrichment ステップを条件ロジックで連結します。最初は高速な model を使い、失敗したものはより高性能な model で再 enrichment します。
スケジュールされた更新— cronスケジュールで実行し、古くなったレコードを最新のAIモデルで再エンリッチします。
Webhook駆動— エンティティデータを受け取り、エンリッチメントして結果を同期的に返すWebhookエンドポイントを公開します。

次のステップ

APIキー

n8n認証情報用のorganizationアクセスキーを作成します。

バッチ処理

並列実行、進捗トラッキング、エクスポートについて学びましょう。

APIリファレンス

高度な連携のための完全な REST API ドキュメントです。