在自动化和系统集成 (system integration) 时代，将不同平台之间的数据同步是常见但充满挑战的任务之一。您有一个来自 CRM 的客户列表、一个来自 Excel 文件的产品表，或来自 IoT 的传感器数据，您需要将它们导入自己的 Supabase 数据库。.
问题出现在您必须回答这个问题时：“这个数据已经存在了吗？”。如果没有，您需要 新增 (Insert). 。如果已经存在，您需要 更新 (Update). 。这个过程被称为 Upsert.
在本文中，我们将深入探讨如何使用 n8n 中的自定义节点 Supabase Upsert 来彻底、高效且性能最优地解决这个问题。.
手动数据同步的痛苦
在进入解决方案之前，让我们回顾一下我们在 n8n 中传统上处理这个问题的常见方式。通常，您必须构建一个相当笨重的 workflow：
- 获取源数据: 从 Google Sheets、Webhook 或 API 读取。.
- 在 Supabase 中查询: 使用一个 Supabase 节点进行 “Select” 以查看相应 ID 的记录是否存在。.
- 检查条件 (IF 节点):
- 如果返回数据为空 (True) -> 跳转到分支 插入.
- 如果数据有返回 (False) -> 跳转到分支 更新.
- 执行: 运行相应的 Insert 或 Update 节点。.
这种方法有许多致命缺点：
- 资源消耗高: 您必须为每行数据执行至少 2 个请求 (Select + Insert/Update)。.
- 速度慢: 处理数千行时，网络延迟 (latency) 会使工作流运行很长时间。.
- 难以维护: 工作流变得复杂，连接线交织，容易出现逻辑错误。.
- 竞态条件风险: 在多线程环境中 (multi-thread)，可能发生两个进程同时检查并发现数据不存在，导致两者都 Insert 并引起重复错误。.
解决方案：自定义 Supabase Upsert 节点
节点 Supabase Upsert 自定义节点旨在完全消除上述复杂性。它将整个“检查和决策”逻辑封装成数据库级别 (Database level) 的单一操作。.
代替 n8n “询问” Supabase 后再“执行”，n8n 只需“下令”： “确保此数据在表中，如果已存在则更新，不存在则新建”. 。Supabase 将处理其余部分。.
为什么这个节点更优秀？
- 最大性能: 将 API 调用数量减少一半，甚至在批量模式下减少 1000 倍。.
- 简化工作流: 用单个节点替换 3-4 个复杂节点。.
- 原子性 (Atomicity): 确保数据完整性，避免竞态条件错误。.
突破性功能
让我们深入分析该节点提供的功能：
1. 基于唯一键的自动 Upsert
节点的核心力量在于定义记录“身份”的能力。通过“On Conflict”参数，您指定包含唯一值 (Unique Key) 的列。.
例如：如果您同步用户，“email” 是唯一的。您在“On Conflict”中填写“email”。当 n8n 发送一个 email 为“test@example.com”的用户时：
- 如果 Supabase 未找到“test@example.com” -> 创建新用户。.
- 如果找到 -> 更新该用户的其他信息 (姓名、年龄、地址…).
2. 批量处理 (Batch Processing)
这是大数据任务的“杀手级”功能。当您启用选项 发送所有项目, 节点不会逐行发送。相反，它将所有输入项目（例如：5000 个产品）收集成一个巨大的 JSON 数组，并在 一个单一请求中发送.
这可以将运行时间从几分钟减少到仅几秒钟。.
3. 冲突解决策略 (Conflict Resolution)
并非每次更新都是你想要的。节点提供 2 种策略：
- 合并（默认）: 标准的 Upsert 行为。新数据将覆盖旧数据。适合同步最新状态。.
- 忽略: “保持原样”。如果数据已存在，Supabase 将什么都不做，只插入新行。适合导入历史数据或日志，在那里你不想更改已记录的内容。.
4. 灵活数据源
您可以使用来自的数据：
- 输入项目: 来自 n8n 中前一个节点的标准数据流。.
- 原始 JSON: 直接输入 JSON 字符串或使用表达式自定义复杂数据结构，而无需在之前使用 “Function” 或 “Set” 节点。.
详细的分步配置指南
为了帮助您掌握此节点，请逐一了解每个配置参数：
步骤 1：连接 (凭证)
您需要创建一个新凭证类型 “Supabase Upsert API”。.
- 项目 URL: 在 Supabase 仪表板的 Settings -> API 中查找。格式为 “https://xyz.supabase.co”。.
- 服务角色密钥: 重要提示, 您应该使用 “service_role” 密钥而不是 “anon” 密钥，以便在需要时绕过 RLS (Row Level Security) 并执行不受权限限制的批量写入操作。.
步骤 2：选择表 (Table)
连接后，节点将自动加载您数据库中的表列表。请选择正确的目标表，例如 “products” 或 “customers”。.
步骤 3：配置 Upsert (最重要)
- 冲突时: 输入具有唯一约束 (Unique Constraint) 的列名。.
- 提示: 如果您使用复合主键 (Composite Key，例如：order_id + product_id)，请用逗号分隔输入它们：order_id, product_id。.
- 解析:
- 选择 “合并” 以始终更新最新值。.
- 选择 “忽略” 如果您只想插入新数据。.
步骤 4：高级选项
- 返回: 选择 “Representation” 以让节点返回刚刚插入/更新的数据（有助于获取自增 ID）。选择 “Minimal” 如果您不关心返回结果以节省网络带宽。.
实际应用场景 (Use Cases)
场景 1：电商库存同步 (高容量)
您有一个包含 10.000 个来自总仓库的产品 CSV 文件，每小时更新一次。.
- 配置:
- 表： “inventory”
- On Conflict: “sku” (SKU)
- Resolution: “Merge”
- Send All Items: “True”
- 结果: 更新10,000个产品的库存数量仅需1-2秒。新SKU将自动添加到销售系统中。.
场景 2：从登陆页面收集潜在客户
您在多个渠道投放广告，数据通过Webhook流入。同一客户可能多次注册。.
- 配置:
- Table: “leads”
- On Conflict: “email”
- Resolution: “Ignore”
- 结果: 您仅保留首次注册信息（First Touch Attribution）。后续注册将被忽略，避免稀释CRM数据。.
场景 3：IoT 传感器日志记录
传感器系统每5分钟发送一次温度数据。有时网络不稳定，传感器会重新发送旧数据包。.
- 配置:
- Table: “sensor_readings”
- On Conflict: “device_id, timestamp”
- Resolution: “Merge”
- 结果: 确保同一时间，每个设备只有一个记录。如果数据重发，它将覆盖旧记录（通常相同），保持数据库整洁。.
常见注意事项和风险
- “On Conflict”错误”: 如果您输入错误的列名或该列在数据库中没有“UNIQUE”约束，Supabase将报错。请确保在SQL Editor中为该列创建Unique Index。.
- SQL创建索引: CREATE UNIQUE INDEX idx_users_email ON public.users (email);
- 请求大小限制: 尽管“Send All Items”非常强大，但Supabase有body大小限制（通常几MB）。一次性发送100,000行可能出错。请分批（Split in Batches）成1,000–5,000行的小组。.
- 访问权限 (RLS): 如果使用“anon” key，请确保已配置Row Level Security允许Insert/Update。对于后端工作流，最好使用“service_role” key。.
总结
节点 Supabase Upsert 不仅仅是一个实用工具，它是n8n中高性能数据集成流程的“骨干”。正确理解和应用此节点将为您节省数小时调试时间，减轻服务器负载，并为系统带来流畅体验。.
如果您正在构建与Supabase的复杂自动化系统，这绝对是您不能错过的节点。立即安装、体验并感受卓越的速度！
