Salesforce 同步代理

要解决的问题

Salesforce 是企业 CRM 的事实标准，客户、线索、联系人等数据分散在各类自定义对象中。团队做报表聚合、跨系统同步或数据迁移时，通常得写一次性脚本直调 REST API：手写分页遍历、自己处理批量写入时的重复记录冲突，稍有不慎就触发 API 调用限额，或在同步任务里插入脏数据。更麻烦的是准实时场景——一个商机状态更新后下游系统要跟着动，轮询 API 既浪费配额，延迟也高。

核心能力与工作方式

这个技能基于 jsforce（原 Node-Salesforce）封装，直接走 Salesforce REST API，提供三类核心操作：

• SOQL 查询：通过 connection.query() 执行任意 SOQL 语句，支持自动分页遍历，适合按条件拉取对象数据做分析、归档或回写。
• 批量 Upsert：通过 connection.sobject().upsertBulk() 按 External ID 做幂等写入，重复执行不会产生重复记录，适合数据迁移和定期同步任务。
• 实时订阅：通过 connection.streaming.topic() 订阅 Platform Events，目标对象的事件触发时立即收到推送，实现准实时的双向同步，而不用反复轮询。

此外 jsforce 是同构库，浏览器和 Node.js 环境都能用；它还自带 REPL 交互式命令行，可以直接试写 SOQL、调试连接，不必先搭工程。

适用边界与注意点

• 批量写入走的仍是 REST 批量端点，百万行级的大型迁移要留意吞吐上限，可考虑 Salesforce 原生 Bulk API 2.0。
• Platform Events 依赖事件总线推送，订阅连接断开后需要自己处理重连和漏事件补偿。
• 认证环节技能不代管：OAuth 登录态（JWT bearer、username/password 等）需要调用方自行获取和维护。
• 实现细节以上游 jsforce 官方 README 为准，复杂对象模型建议先用 REPL 小批量验证再上量。