Conector n8n

O nó comunitário do Entity Enricher para n8n permite-lhe criar pipelines de enriquecimento automatizados com um editor visual de arrastar e largar. Ligue-se a mais de 400 aplicações sem escrever código.

Instalação

Instale o nó comunitário na sua instância do n8n:

npm install n8n-nodes-entity-enricher

Ou instale através da interface do n8n: aceda a Definições → Community Nodes e procure por n8n-nodes-entity-enricher.

Pré-requisitos

Chave de APICrie uma chave de acesso de organização no Entity Enricher. Consulte a documentação de chaves de API para mais detalhes. O formato da chave é ent_XXXXXXXXXXXX.
URL baseO URL da sua instância do Entity Enricher (por exemplo, https://entityenricher.ai ou o seu URL self-hosted).
Configuração de credenciaisNo n8n, crie uma credencial Entity Enricher API com a sua API key e URL base. Todos os nós utilizarão esta credencial. Uma chave de acesso de organização funciona de forma independente de qualquer conta de utilizador — a recomendação para fluxos de trabalho serviço a serviço duradouros.
OAuth2 (alternativa)Prefere ligar-se com a sua conta? Crie antes uma credencial Entity Enricher OAuth2 API: copie o URL de redirecionamento OAuth que o n8n apresenta, registe um cliente OAuth com ele em Entity Enricher, em API Keys → Aplicações Ligadas → Clientes OAuth (função de proprietário), cole o ID do cliente no n8n e clique em Ligar a minha conta. A ligação atua com a sua própria função e é revogável a qualquer momento em Aplicações Ligadas. Selecione a credencial no nó com o respetivo parâmetro Autenticação.
  1. 1O nome apresentado em Aplicações Ligadas
  2. 2O URL de redirecionamento OAuth do n8n, copiado exatamente
  3. 3Devolve o ID de cliente para colar no n8n
Um cliente não pode ser editado posteriormente — o respetivo URL de redirecionamento é fixado na criação, pelo que uma segunda instância n8n recebe o seu próprio cliente, e eliminar um revoga de imediato todas as ligações feitas através dele.

Operações disponíveis

O conector expõe 18 operações em 7 categorias de recursos:

RecursoOperaçãoDescrição
EnrichmentEnrich EntityEnriqueça uma única entidade — basta escolher um esquema; o melhor modelo e estratégia da sua organização são selecionados automaticamente. Transmite os resultados via SSE com progresso em tempo real.
EnrichmentEnrich Entity AdvancedEnriqueça uma única entidade com controlo total sobre modelos, fusão, estratégia, classificação e saída estruturada.
EnrichmentBatch EnrichEnriqueça todos os itens de entrada como um único lote com o modelo e estratégia automáticos. Processamento paralelo com acompanhamento de progresso por entidade.
EnrichmentBatch Enrich AdvancedEnriqueça todos os itens de entrada como um único lote com o conjunto completo de parâmetros.
SchemaList SchemasListar os schemas guardados disponíveis para seleção nos fluxos de trabalho de enriquecimento.
SchemaGet Schema DetailsObter o conteúdo completo do esquema com as propriedades-chave extraídas de um esquema específico.
SchemaGenerate SampleGere 1..N objetos JSON de amostra realistas de um tipo de entidade num único trabalho — o ponto de entrada do ciclo de criação de esquemas. O idioma assume por predefinição auto, inferido a partir das palavras do seu próprio pedido.
SchemaGenerate SchemaGere e guarde automaticamente um esquema JSON — cada item de entrada é uma amostra do mesmo tipo de entidade: união dos campos, anulável quando um campo falta nalguma amostra, valores reais observados como exemplos. Uma opção Idioma define o idioma em que o esquema se descreve a si próprio.
RecordList RecordsConsulte registos de enriquecimento com filtros de tipo e de sucesso. Resultados paginados.
RecordGet RecordObter um resultado de enriquecimento específico por ID com saída estruturada completa.
RecordSync Records to DatabaseEnvie um resultado de enriquecimento guardado (ou transformado) para a sincronização de base de dados do respetivo schema — revalidado face ao contrato publicado e depois passado pelo controlo de admissão.
FusionMerge ResultsFunda resultados de vários registos de enriquecimento com arbitragem LLM opcional.
AttachmentAdd AttachmentCarregue um ou mais ficheiros binários do item de entrada (pedido multipart único) e devolva um item por ID de anexo.
AttachmentDelete AttachmentEliminar um anexo por ID — um passo prático de limpeza pós-enriquecimento.
Database SyncList Database SyncsListe as database syncs registadas num esquema, com as contagens de deltas pendentes.
Database SyncFetch DeltasObtenha a próxima janela FIFO de deltas de base de dados (SQL + JSON), opcionalmente reservando-os (lease) para confirmação.
Database SyncAcknowledge DeltasConfirme os deltas aplicados até um ID — liberta o lease e, consoante as opções de sincronização, elimina as cópias entregues.
ConfigurationGet OptionsObtenha os modelos, idiomas, estratégias e limites de plano disponíveis para configuração dinâmica.

Nó acionador

O pacote inclui ainda um nó Entity Enricher Trigger separado — um acionador de webhook que inicia um fluxo de trabalho a partir de qualquer evento da plataforma, registando automaticamente a respetiva subscrição. A lista pendente Event é carregada em tempo real a partir da sua conta, pelo que todos os eventos emitidos pela plataforma estão disponíveis sem atualizar o nó:

Registos de enriquecimentorecord.created é acionado em cada enriquecimento concluído (com ou sem database sync). Opcionalmente, pode restringi-lo a um único schema. Uma execução que não passou no controlo de admissão de um database sync chega com database.saved = false e a lista de campos obrigatórios em falta.
Contas, faturação e créditosmember.*, subscription.*, credits.* — um pedido de adesão, uma alteração de função, uma mudança para um plano superior, uma compra de créditos ou um saldo baixo/esgotado. Todos os eventos "updated" incluem um mapa de alterações que indica exatamente que atributo mudou.
Tarefas e esquemasjob.completed / job.failed para qualquer tarefa LLM — enriquecimento, lote, benchmark, amostra ou geração de schema — e schema.updated quando um schema é publicado, que é o sinal a aguardar antes de ler uma nova estrutura. Uma tarefa falhada inclui um error_code tipado junto da mensagem.
Fornecedores de IAprovider.failed quando uma chamada a um fornecedor de IA falha do lado do fornecedor após as tentativas — limite de taxa, timeout, modelo descontinuado, conta sem créditos — com data.code a indicar qual; provider.threshold quando a conta associada a uma chave de fornecedor fica sem créditos, uma vez por chave, com key_source a indicar se é a sua própria chave ou a chave partilhada.
Deltas de base de dados disponíveisÉ acionado quando novos deltas SQL estão prontos para um Database Sync. Com "Fetch Deltas on Fire" ativado, o nó obtém e reserva os deltas pendentes, emitindo um item por delta para um passo Acknowledge Deltas a jusante. Uma base de dados alimentada por vários esquemas notifica por esquema — cada um aciona o seu próprio fluxo de trabalho — por isso, escolha qual o esquema associado que este acionador escuta.

Cada entrega é assinada: um cabeçalho X-EE-Signature transporta um HMAC-SHA256 do corpo com data e hora, e X-EE-Delivery mantém-se estável entre tentativas, pelo que o pode usar como chave de idempotência. As entregas falhadas são repetidas três vezes ao longo de meia hora. Também pode registar endpoints manualmente — sem qualquer conector — em Definições › Webhooks, onde um registo de entregas mostra todas as tentativas e permite repetir qualquer uma.

  1. 1Os eventos que este endpoint subscreve
  2. 2A chave por trás de X-EE-Signature
  3. 3Uma linha por tentativa, com estado e latência
A linha é escrita antes do primeiro POST, pelo que o log serve de trilho de auditoria mesmo quando nada chega ao seu consumidor — e um endpoint que falha dez entregas seguidas é desativado em vez de acumular fila para um URL que ninguém está a escutar.

Juntamente com as operações do Database Sync, o acionador mantém uma base de dados externa convergida apenas a partir do n8n — consulte a documentação do Database Sync.

  1. 1A janela que o trigger monitoriza
  2. 2Voltar ao enriquecimento que produziu o delta
  3. 3A instrução que a sua base de dados aplica, protegida por revisão
O que o trigger anuncia e o Fetch Deltas reserva: linhas ordenadas, cada uma com a instrução exata a aplicar e o enriquecimento de onde veio.

Enriquecimento de entidade individual

O fluxo de trabalho mais simples: acione com novos dados, enriqueça uma única entidade e envie o resultado para o seu destino. O nó aguarda a conclusão total do enriquecimento antes de passar a saída estruturada a jusante.

Exemplo de fluxo de trabalho — enriquecimento de uma única entidade:

Configuração do nó — operação de enriquecimento de entidade:

Configuração

As operações predefinidas Enrich Entity e Batch Enrich mostram apenas o essencial: esquema, carregamento de ficheiro, idiomas e pesquisa na web. O Entity Enricher é executado automaticamente com o melhor modelo da sua organização — a sua predefinição fixada ou o modelo com a pontuação de benchmark mais elevada — e escolhe a estratégia de enriquecimento a partir do seu esquema. As operações Enrich Entity Advanced e Batch Enrich Advanced expõem o conjunto completo de opções abaixo.

Selecione um esquema na lista pendente dinâmica, escolha um ou mais modelos e forneça os dados da entidade como campos chave-valor. O nó preenche automaticamente os campos de chave de pesquisa com base no esquema selecionado.

As definições opcionais incluem estratégia (passagem única ou multi-expertise domain), idiomas para saída multilíngue, modelo de classification para verificação do tipo de entity, modelo de arbitration para resolução de conflitos entre múltiplos modelos e as opções de schema de resposta / saída estruturada estrita que impõem uma saída conforme ao schema em modelos capazes.

Para fornecer documentos de origem ao enriquecimento, ative Carregar Ficheiros Binários de Entrada: o nó carrega os ficheiros binários do item de entrada como anexos num único pedido (todos eles, ou apenas os indicados em Campos Binários a Carregar) e, com Eliminar Anexos Carregados Após o Enriquecimento (ativado por predefinição), remove-os assim que o enriquecimento termina — sem necessidade de passos separados de Add Attachment / Delete Attachment. Em alternativa, forneça um campo IDs de Anexo (UUIDs separados por vírgulas de chamadas Add Attachment anteriores) para reutilizar documentos carregados uma só vez em vários enriquecimentos; ambas as fontes podem ser combinadas. Também disponível no Batch Enrich, onde os ficheiros são recolhidos de todos os itens de entrada e aplicados a todas as entidades do trabalho. Se um nó Edit Fields estiver entre a fonte dos ficheiros e o nó de enriquecimento, ative o respetivo interruptor Incluir Outros Campos de Entrada — caso contrário, remove os dados binários.

Enriquecimento em Lote

Processe todos os itens de entrada como um único batch. Ideal para enriquecer listas de folhas de cálculo, bases de dados ou respostas de API. Todas as entidades são processadas em paralelo com limitação de taxa por provider.

Configuração do nó — operação de enriquecimento em lote:

Como funciona o Modo Batch

  1. Recolher itens — O nó reúne todos os itens de entrada do nó anterior (por exemplo, linhas de uma folha de cálculo).
  2. Iniciar tarefa em lote — Todas as entidades são submetidas via POST /api/batch/start e processadas em paralelo.
  3. Transmitir progresso — O nó consome o fluxo SSE até que todas as entidades terminem ou o tempo limite seja atingido.
  4. Resultados de saída — Um item de saída por entidade com os dados estruturados enriquecidos, prontos para processamento posterior.

Principais funcionalidades

Operações Simples e Avançadas

As operações predefinidas Enrich Entity e Batch Enrich mostram apenas esquema, carregamento de ficheiro, idiomas e pesquisa na web — o melhor modelo e estratégia são selecionados automaticamente. As operações Advanced dão controlo total sobre modelos, fusão, estratégia e saída estruturada.

Menus pendentes dinâmicos

Os seletores de esquema, modelo, idioma e estratégia obtêm as opções da sua instância de Entity Enricher no momento da configuração.

Streaming SSE

As operações de enriquecimento consomem o fluxo SSE em tempo real, aguardando a conclusão antes de devolver os resultados ao nó seguinte.

Continuação Automática

Quando a classification de pré-verificação deteta uma incompatibilidade, o conector continua automaticamente (os fluxos de trabalho do n8n são não interativos).

Tempo limite configurável

Tempo limite predefinido de 300 segundos por chamada de enriquecimento, ajustável por nó para esquemas grandes ou modelos lentos.

Suporte Multi-Modelo

Selecione vários modelos por enriquecimento. Quando são utilizados 2+ modelos, os resultados são automaticamente fundidos.

Limpar saída por predefinição

Por predefinição, o resultado contém apenas os campos de dados enriquecidos. Ative "Incluir Metadados de Enriquecimento" para adicionar custo, tokens, detalhes de fusão e IDs de registo.

Saída por modelo

Opcionalmente, produza os resultados individuais de cada modelo juntamente com o resultado de fusion para comparação posterior.

Consciência dos Limites do Plano

Os menus de model e de idioma apresentam os limites do plano quando configurados. Os erros HTTP 402 resultantes da aplicação de quotas são apresentados como mensagens claras e acionáveis, com os detalhes dos limites. Os metadados de saída incluem os limites atuais do plano para o encaminhamento a jusante.

Utilize-o a partir de um Agente de IA ou comece por um exemplo

Uma ferramenta de AI Agent

O nó Entity Enricher pode ser ligado a um AI Agent do n8n como ferramenta, permitindo que um agente decida por si quando enriquecer uma entidade ou obter um esquema a meio de uma conversa. O nó de gatilho não é deliberadamente disponibilizado desta forma — um gatilho inicia um workflow, não é algo que um agente invoque.

Seis fluxos de trabalho importáveis

O pacote inclui ficheiros de workflow prontos a usar — enriquecimento único, lote, documento para enriquecimento, imagem para amostra para esquema, amostras para esquema e esvaziamento de um feed de deltas para PostgreSQL. Importe um e substitua pela sua própria credencial, em vez de o montar de raiz.

Ideias de Fluxos de Trabalho

Padrões comuns para construir pipelines de enriquecimento com o n8n:

Enriquecimento de CRMAcione em novos contactos do HubSpot/Salesforce, enriqueça com dados da empresa e atualize o registo no CRM.
Pipeline de folha de cálculoLeia entities a partir do Google Sheets, faça enrichment em batch e escreva os resultados numa nova folha.
Enriquecimento em cascataEncadeie vários passos de enriquecimento com lógica condicional — utilize primeiro um modelo rápido e volte a enriquecer as falhas com um modelo mais capaz.
Atualização agendadaExecute num agendamento cron para re-enriquecer registos desatualizados com os modelos de IA mais recentes.
Orientado por WebhookExponha um endpoint de webhook que aceita dados de entidades, os enriquece e devolve o resultado de forma síncrona.

Próximos Passos