n8n 连接器 - Entity Enricher 文档

n8n 连接器

适用于 n8n 的 Entity Enricher 社区节点让你可以通过可视化拖放编辑器构建自动化丰富化流程。无需编写代码即可连接 400 多个应用。

安装

在您的 n8n 实例中安装社区节点:

npm install n8n-nodes-entity-enricher

或通过 n8n 界面安装:进入Settings → Community Nodes,搜索 n8n-nodes-entity-enricher

前置条件

API 密钥在 Entity Enricher 中创建组织访问密钥。详情请参阅API 密钥文档。密钥格式为 ent_XXXXXXXXXXXX
基础 URL你的 Entity Enricher 实例的 URL(例如 https://entityenricher.ai 或你的自托管 URL)。
凭据设置在 n8n 中,使用你的 API 密钥和基础 URL 创建一个 Entity Enricher API 凭据。所有节点都将使用此凭据。组织访问密钥独立于任何用户账户运行——这是持久化服务间工作流的推荐做法。
OAuth2(备选)更倾向于使用你的账户连接?可改为创建一个 Entity Enricher OAuth2 API 凭据:复制 n8n 显示的 OAuth 重定向 URL,在 Entity Enricher 的 API 密钥 → 已连接应用 → OAuth 客户端(所有者角色)下用该 URL 注册一个 OAuth 客户端,将客户端 ID 粘贴到 n8n 中,然后点击连接我的账户。该连接以你自己的角色运行,并可随时在已连接应用下撤销。在节点上通过其 Authentication 参数选择该凭据。

可用操作

该连接器在 7 个资源类别中提供 18 项操作:

资源操作描述
EnrichmentEnrich Entity富集单个实体——只需选择一个 schema;系统会自动选择您所在组织的最佳模型和策略。通过 SSE 实时流式返回结果与进度。
EnrichmentEnrich Entity Advanced富集单个实体,并可完全控制模型、融合、策略、分类和结构化输出。
EnrichmentBatch Enrich使用自动模型和策略将所有输入项作为单个批次进行富集。并行处理,并按实体跟踪进度。
EnrichmentBatch Enrich Advanced使用完整参数集将所有输入项作为单个批次进行富集。
SchemaList Schemas列出可供在增强工作流中选择的已保存模式。
SchemaGet Schema Details检索特定 schema 的完整 schema 内容及提取的关键属性。
SchemaGenerate Sample在单个作业中生成 1..N 个同一实体类型的真实样本 JSON 对象 —— 这是模式编写流程的入口。语言默认为 auto,根据你请求中的用词推断。
SchemaGenerate Schema生成并自动保存 JSON 模式 —— 每个输入项都是同一实体类型的一个样本:字段取并集,在部分样本中缺失的字段设为可空,并以实际观察到的值作为示例。语言选项用于设置模式自我描述所使用的语言。
RecordList Records按类型和成功状态筛选查询富集记录。结果分页显示。
RecordGet Record按 ID 检索特定的 enrichment 结果,包含完整的结构化输出。
RecordSync Records to Database将已存储(或经过转换)的增强结果发送到其模式的数据库同步——先按已发布的契约重新校验,再通过准入关卡。
FusionMerge Results融合来自多条丰富记录的结果,可选 LLM 仲裁。
AttachmentAdd Attachment从输入项上传一个或多个二进制文件(单个 multipart 请求),并为每个附件 ID 返回一个项目。
AttachmentDelete Attachment按 ID 删除附件——便捷的丰富后清理步骤。
Database SyncList Database Syncs列出某个模式上注册的数据库同步,及其待处理增量数量。
Database SyncFetch Deltas获取下一个 FIFO 窗口的数据库增量(SQL + JSON),并可选择性地租用它们以便确认。
Database SyncAcknowledge Deltas确认截至某个 ID 的已应用增量——释放租约,并根据同步选项清除已投递的副本。
ConfigurationGet Options获取可用的模型、语言、策略和套餐限制,用于动态配置。

触发器节点

该软件包还附带一个独立的 Entity Enricher Trigger 节点——这是一个 webhook 触发器,在模式事件发生时启动工作流,并自动注册其订阅:

富化结果每当所选模式完成一次富化时触发(无论是否配置数据库同步)。
已拒绝保存到数据库当一次富化未通过数据库同步的准入校验时触发——载荷会告诉你缺少了哪些必填字段。
数据库增量可用当某个 Database Sync 有新的 SQL 增量就绪时触发。启用“Fetch Deltas on Fire”后,该节点会获取并租用待处理的增量,为每条增量输出一个数据项,供下游的 Acknowledge Deltas 步骤使用。由多个模式供数的数据库会按模式分别发送通知 —— 每个模式驱动各自的工作流 —— 因此请选择此触发器监听哪个已关联的模式。

结合 Database Sync 操作,该触发器仅通过 n8n 即可让外部数据库保持收敛——参见 Database Sync 文档

单实体增强

最简单的工作流:在有新数据时触发,enrich 单个 entity,并将结果推送到你的目标位置。该节点会等待完整的 enrichment 完成后,再将结构化输出向下游传递。

工作流示例——单个实体扩充:

节点配置——Enrich Entity 操作:

用于单次增强的 Entity Enricher 节点配置

配置

默认的 富集实体批量富集 操作仅显示必要项:schema文件上传语言网页搜索。Entity Enricher 会自动使用您所在组织的最佳模型运行——即您固定的默认模型,或基准测试得分最高的模型——并根据您的 schema 选择富集策略。富集实体(高级)批量富集(高级) 操作则提供下方的完整选项集。

从动态下拉菜单中选择一个 schema,选择一个或多个 model,并以键值字段形式提供 entity 数据。节点会根据所选 schema 自动填充搜索键字段。

可选设置包括策略(单遍或多专业领域)、用于多语言输出的语言、用于实体类型验证的分类模型、用于多模型冲突解决的仲裁模型,以及响应 schema / 严格结构化输出开关,可在支持的模型上强制输出符合 schema 的结果。

如需将源文档送入丰富处理,请打开 Upload Input Binary Files(上传输入二进制文件):该节点会在单个请求中将输入项的二进制文件作为附件上传(全部文件,或仅上传 Binary Fields to Upload(要上传的二进制字段)中指定的文件),并在开启 Delete Uploaded Attachments After Enrichment(丰富完成后删除已上传的附件,默认开启)时于丰富处理结束后将其清理 —— 无需单独的 Add Attachment / Delete Attachment 步骤。或者,也可提供 Attachment IDs(附件 ID)字段(来自先前 Add Attachment 调用的逗号分隔 UUID),以便将一次上传的文档在多次丰富处理中复用;两种来源可以结合使用。此功能在批量丰富中同样可用,届时会从所有输入项收集文件并应用于作业中的每个实体。如果文件来源与丰富节点之间存在 Edit Fields 节点,请启用其 Include Other Input Fields(包含其他输入字段)开关 —— 否则它会剥离二进制数据。

批量丰富化

将所有输入项作为单个批处理进行处理。非常适合从电子表格、数据库或 API 响应中富集列表。所有实体都会并行处理,并按提供商进行速率限制。

节点配置——Batch Enrich 操作:

用于批量增强的 Entity Enricher 节点配置

批量模式的工作原理

  1. 收集项目——节点会从上一个节点收集所有输入项目(例如电子表格中的行)。
  2. 启动 batch 任务——所有 entity 都通过 POST /api/batch/start 提交并并行处理。
  3. 流式进度——该节点会持续消费 SSE 流,直到所有 entity 完成或达到超时。
  4. 输出结果 — 每个实体对应一个输出项,包含增强后的结构化数据,可供下游处理。

主要特性

简单与高级操作

默认的富集实体和批量富集操作仅显示 schema、文件上传、语言和网页搜索——最佳模型和策略会自动选择。高级操作则可完全控制模型、融合、策略和结构化输出。

动态下拉菜单

Schema、模型、语言和策略选择器会在配置时从你的 Entity Enricher 实例获取可选项。

SSE 流式传输

丰富化操作实时消费 SSE 流,等待完成后再将结果返回给下一个节点。

自动继续

当预检分类检测到不匹配时,连接器会自动继续(n8n 工作流为非交互式)。

可配置超时

每次 enrichment 调用默认超时 300 秒,可针对大型 schema 或较慢的模型按节点进行调整。

多模型支持

每次 enrichment 可选择多个 model。使用 2 个以上 model 时,结果会自动进行 fusion。

默认清理输出

默认情况下,输出仅包含丰富后的数据字段。开启“包含丰富元数据”可添加成本、令牌、融合详情和记录 ID。

各模型输出

可选择在融合结果之外一并输出各个模型的单独结果,供下游比较。

套餐限额提示

配置后,模型和语言下拉菜单会显示套餐限制。配额强制执行产生的 HTTP 402 错误会以清晰、可操作的消息呈现,并附带限制详情。元数据输出包含当前套餐限制,供下游路由使用。

在 AI 智能体中使用,或从示例开始

一个 AI 智能体工具

Entity Enricher 节点可作为工具挂载到 n8n 的 AI Agent 上,让智能体在对话过程中自行决定何时扩充实体或获取模式。触发器节点有意不以这种方式提供——触发器用于启动工作流,而不是供智能体调用的对象。

六个可导入的工作流

该软件包内置现成的工作流文件——单条扩充、批量、文档转扩充、图片转示例转模式、示例转模式,以及把增量数据流导入 PostgreSQL。直接导入其中一个并换成你自己的凭据,无需从零搭建。

工作流创意

使用 n8n 构建 enrichment 流水线的常见模式:

CRM 富集在新增 HubSpot/Salesforce 联系人时触发,用公司数据进行增强,并更新 CRM 记录。
电子表格流水线从 Google Sheets 读取实体,批量增强,并将结果写回新的工作表。
瀑布式增强使用条件逻辑串联多个数据丰富化步骤——先使用快速模型,再用能力更强的模型重新丰富化失败的记录。
定时刷新按 cron 计划运行,用最新 AI 模型重新充实过时记录。
由 Webhook 驱动公开一个 webhook 端点,接受实体数据、对其进行富化并同步返回结果。

后续步骤