用 n8n + Peliqan 搭建 RAG + Text-to-SQL 业务数据聊天机器人

输入：多源业务数据（CRM/Notion/ERP）→ 处理：Peliqan 同步 + Supabase 向量存储 + AI Agent 路由 → 输出：自然语言查询答案

给谁

需要在 n8n 中搭建能查询内部业务数据的 AI 聊天机器人的团队

你会得到

用户用自然语言提问，AI Agent 自动选择 RAG（知识检索）或 Text-to-SQL（数据分析）回答

你需要

n8n · supabase · peliqan

步骤

1. 准备 Peliqan 账号与数据源

   在 peliqan.io 注册免费试用账号。在 Peliqan 中添加一个或多个业务数据源（如 Hubspot、Pipedrive、Notion 等）。Peliqan 会通过一键 ELT 将数据同步到其内置数据仓库。

2. 配置 n8n 凭证与自托管环境

   在 n8n 中配置三类凭证：openAiApi（OpenAI API Key）、supabaseApi（Supabase 项目 URL 和 service key）、peliqanApi（从 Peliqan Settings 复制的 API Key）。**仅限自托管 n8n**：在运行 n8n 的服务器/容器中设置环境变量 `export N8N_COMMUNITY_PACKAGES_ALLOW_TOOL_USAGE=True`，否则 Peliqan 节点无法作为 AI Agent 的工具使用。

   搭建指导 · 来源原文。n8n 自托管服务器的环境变量配置

   复制提示词

   export N8N_COMMUNITY_PACKAGES_ALLOW_TOOL_USAGE=True

3. 运行数据同步工作流向量入库

   手动执行工作流中的「When clicking 'Execute workflow'」分支：Peliqan 节点「Get table data」从指定表拉取数据 → Default Data Loader 将标题和内容拼接为文档 → Recursive Character Text Splitter（chunkSize=500, chunkOverlap=100）分块 → Embeddings OpenAI 生成向量 → 插入 Supabase Vector Store（表名 documents，含 metadata source_url 和 title）。如需更换源表，修改「Get table data」节点的 tableId。

   运行提示词 · 来源原文。Default Data Loader 节点的 jsonData 表达式字段

   复制提示词

   =# {{ $json.title + '\n' + $json.content }}

4. 配置 AI Agent 系统提示词与数据模型

   打开 AI Agent 节点的 System Message，保留角色定义和工具使用说明。将提示词中「This is the data model of tables & columns」下方的示例 schema 替换为你实际 Peliqan 数据源的表和列名。来源中的示例包含 chargebee.customers、chargebee.credit_notes、chargebee.invoices 等表，但你的环境需使用真实表结构。

   运行提示词 · 来源原文。AI Agent 节点的 System Message 字段；注意来源为节选，实际部署需替换为完整数据模型

   复制提示词

   You are an assistant answering questions on internal business data.
   
   You can use the Vector Store to find info, which contains all pages of Notion (intranet) with internal knowledge.
   
   You can also run SQL queries for quantitive questions on tables. To execute an SQL query: send the query to Peliqan tool "Execute SQL" in a key SQL_Query__View_. Get the results from key "detail".
   
   This is the data model of tables & columns that can be used in SQL queries:
   
   Columns in table chargebee.customers:
   
   customer_id
   customer_first_name
   customer_last_name
   customer_email
   customer_phone
   
   Columns in table chargebee.credit_notes:
   
   credit_note_id
   credit_note_customer_id
   credit_note_subscription_id
   credit_note_reference_invoice_id
   credit_note_type
   
   Columns in table chargebee.invoices:
   
   invoice_id
   invoice_customer_id
   invoice_subscription_id
   
   (etc. truncated)

5. 激活工作流并开始对话

   保存并激活工作流。通过「When chat message received」触发器的公开 URL 或 n8n 内置 Chat 界面发送消息。AI Agent 会根据问题类型自动路由：知识类问题调用 Supabase Vector Store（RAG），数据分析问题调用 Peliqan Execute SQL 工具（Text-to-SQL），也可组合使用。Simple Memory 节点维护对话上下文。

在 n8n 中导入此模板后，按步骤配置 Peliqan、Supabase、OpenAI 凭证，设置自托管环境变量，替换 AI Agent 中的数据模型 schema，然后激活工作流即可开始测试。