利用 Heroku Connect 实现实时 Salesforce 数据集成

十月 18, 2025

背景与应用场景

作为一名 Salesforce 集成工程师，我的核心职责是打通 Salesforce 与外部系统之间的数据和流程壁垒，构建高效、稳定且可扩展的集成解决方案。在 Salesforce 生态系统中，Heroku 扮演着至关重要的角色。Heroku 是一个成熟的 Platform as a Service (PaaS, 平台即服务)，它允许开发者使用多种主流编程语言（如 Node.js, Ruby, Python, Java, Go）构建、部署和管理应用程序，而无需关心底层的基础设施。

Salesforce 与 Heroku 的结合为我们提供了解决复杂业务场景的强大能力。虽然 Salesforce Platform 本身功能强大，但在某些特定场景下，我们会遇到平台的限制，例如 Apex 的计算限制 (CPU time limits)、严格的 API 调用频率、以及对特定开源技术栈的支持不足。这时，Heroku 就成为了 Salesforce 的完美延伸。

常见的应用场景包括：

构建高性能的客户体验应用 (Customer-facing Applications)：当需要为大量终端用户（非 Salesforce 用户）构建一个需要与 Salesforce 数据实时交互的门户网站、移动应用后端或电商平台时，Heroku 提供了无与伦比的弹性和可扩展性。例如，一个电商网站的订单状态需要实时从 Salesforce 的 Order 对象中读取和更新。
数据密集型处理与计算：对于需要进行大规模数据清洗、复杂报表生成、机器学习模型训练等消耗大量计算资源的任务，将其从 Salesforce 中剥离出来，放到 Heroku 上执行是最佳实践。这可以有效避免触及 Salesforce 的 Governor Limits (治理限制)。
构建复杂的集成中间件：当 Salesforce 需要与多个遗留系统或第三方服务进行交互时，可以在 Heroku 上构建一个统一的集成层 (Middleware)。这个中间件负责协议转换、数据格式化、以及复杂的业务流程编排，从而简化 Salesforce 端的集成逻辑。
利用丰富的开源生态：开发者希望利用 Python 的数据分析库 (Pandas, Scikit-learn) 或 Node.js 的实时通讯库 (Socket.IO) 等特定技术栈时，Heroku 提供了原生的支持环境。

在这些场景中，最核心的挑战是如何实现 Salesforce 与 Heroku 应用之间高效、可靠的数据同步。这正是 Heroku Connect 发挥关键作用的地方。

原理说明

Heroku Connect 是 Salesforce 提供的一项数据同步服务，旨在简化 Heroku 平台与 Salesforce 组织之间的数据集成。它在 Heroku 应用的 Heroku Postgres 数据库与 Salesforce 的标准/自定义对象之间建立了一个双向或单向的数据桥梁。

其核心工作原理可以概括为以下几点：

1. 声明式配置

集成工程师无需编写一行代码即可完成数据同步的配置。通过 Heroku Connect 的可视化仪表盘，我们可以选择需要同步的 Salesforce 对象，然后将其映射 (Mapping) 到 Heroku Postgres 数据库中的一张数据表。我们可以精确地选择需要同步哪些字段，并定义同步方向。

2. 双向数据同步机制

Heroku Connect 支持两种主要的同步方向：

从 Salesforce 到 Heroku (Salesforce-to-Heroku)：这是最常见的模式。当 Salesforce 中的记录发生创建、更新或删除时，Heroku Connect 会通过 Salesforce 的 Streaming API 或定期轮询 (Polling) 机制近乎实时地捕捉这些变更，并将其应用到对应的 Postgres 数据表中。这使得 Heroku 应用可以始终访问最新的 Salesforce 数据。
从 Heroku 到 Salesforce (Heroku-to-Salesforce)：当 Heroku 应用中的数据（即 Postgres 数据库中的记录）发生变化时，Heroku Connect 会通过 Salesforce 的 SOAP API 或 Bulk API 将这些变更写回到 Salesforce。这意味着 Heroku 应用可以安全地修改 Salesforce 数据，而无需直接处理复杂的 API 调用和认证。

3. 数据抽象层

对于运行在 Heroku 上的应用程序来说，它完全不需要感知 Salesforce API 的存在。开发者只需像操作一个标准的 Postgres 数据库一样，对映射好的数据表进行 CRUD (Create, Read, Update, Delete) 操作即可。Heroku Connect 在后台处理了所有与 Salesforce API 的交互、认证、错误重试和数据转换等复杂工作。这种抽象极大地降低了开发门槛，并提升了开发效率。

4. 底层技术

Heroku Connect 综合利用了多种 Salesforce API 来实现高效同步。对于从 Salesforce 到 Heroku 的数据同步，它优先使用 Streaming API (基于 Bayeux/CometD 协议) 来实现事件驱动的近实时更新。如果 Streaming API 不可用或配置未启用，它会回退到固定时间间隔的轮询模式。对于从 Heroku 到 Salesforce 的数据写入，它会根据数据量和操作类型智能地选择使用 SOAP API 或 Bulk API，以优化性能和 API 调用消耗。

总而言之，Heroku Connect 充当了一个智能的数据代理，让 Heroku Postgres 数据库成为了 Salesforce 数据的一个高保真、可读写的“镜像”。

示例代码

虽然 Heroku Connect 的核心是无代码配置，但在实际的集成场景中，我们常常需要从 Salesforce 内部主动触发 Heroku 应用上的某个特定服务。例如，当一个“案例 (Case)”被关闭时，我们可能需要调用 Heroku 上的一个服务来生成一份详细的 PDF 报告并发送给客户。这种场景就需要通过 Apex Callout 来实现。

以下示例代码展示了如何从 Salesforce Apex 中调用一个部署在 Heroku 上的 RESTful API 端点。此代码严格遵循 Salesforce 官方文档规范。

Apex Callout to a Heroku Service

// 这是一个示例类，用于向 Heroku 上托管的外部服务发起 HTTP POST 请求。
// 假设 Heroku 上有一个服务，其端点为 https://your-heroku-app.herokuapp.com/api/generateReport
// 该服务接收一个 JSON 体，其中包含 Case 的 ID 和状态。
public class HerokuIntegrationService {

    // 推荐使用 Named Credential (命名凭据) 来管理端点 URL 和认证信息，而不是硬编码。
    // 在 Salesforce 设置中创建一个名为 'Heroku_Service' 的 Named Credential。
    private static final String HEROKU_ENDPOINT = 'callout:Heroku_Service/api/generateReport';

    @future(callout=true)
    public static void callHerokuToGenerateReport(Id caseId, String status) {
        // 创建 HTTP 请求对象
        HttpRequest req = new HttpRequest();
        
        // 设置请求端点，这里使用了 Named Credential 的合并字段语法
        req.setEndpoint(HEROKU_ENDPOINT);
        
        // 设置请求方法为 POST
        req.setMethod('POST');
        
        // 设置请求头，指定内容类型为 JSON
        req.setHeader('Content-Type', 'application/json;charset=UTF-8');

        // 构建请求体 (Request Body)
        // 使用 JSON.serialize 来将 Apex 对象转换为 JSON 字符串
        Map<String, String> bodyMap = new Map<String, String>{
            'caseId' => caseId,
            'status' => status
        };
        String requestBody = JSON.serialize(bodyMap);
        req.setBody(requestBody);

        // 创建 HTTP 客户端实例
        Http http = new Http();
        HttpResponse res = null;

        try {
            // 发送请求并获取响应
            res = http.send(req);

            // 处理响应
            if (res.getStatusCode() == 200 || res.getStatusCode() == 201) {
                // 请求成功，记录成功日志或更新相关记录
                System.debug('Successfully called Heroku service. Response: ' + res.getBody());
            } else {
                // 请求失败，处理错误
                System.debug('Error calling Heroku service. Status: ' + res.getStatus());
                System.debug('Status Code: ' + res.getStatusCode());
                System.debug('Response Body: ' + res.getBody());
                // 在这里可以添加更复杂的错误处理逻辑，例如创建一个任务或发送通知
            }
        } catch (System.CalloutException e) {
            // 捕获可能发生的调用异常，例如 DNS 解析失败、超时等
            System.debug('Callout error: ' + e.getMessage());
        }
    }
}

如何使用这个示例: 我们可以创建一个 Apex Trigger，当 Case 的状态变为 "Closed" 时，调用这个 @future 方法。

trigger CaseTrigger on Case (after update) {
    for (Case c : Trigger.new) {
        // 检查案例是否从非关闭状态变为关闭状态
        if (c.IsClosed && !Trigger.oldMap.get(c.Id).IsClosed) {
            // 异步调用 Heroku 服务
            HerokuIntegrationService.callHerokuToGenerateReport(c.Id, c.Status);
        }
    }
}

注意事项

在使用 Heroku 和 Heroku Connect 时，集成工程师必须考虑以下几点：

API 调用限制 (API Limits)：Heroku Connect 的每次同步操作都会消耗 Salesforce 的 API 调用配额。对于大规模数据的双向同步，这可能会对组织的 API 总量造成压力。需要预先评估数据量和变更频率，并监控 API 使用情况。
数据同步延迟 (Data Latency)：虽然 Heroku Connect 致力于实现近实时同步，但它并非绝对的实时。根据网络状况和 Salesforce 平台的负载，数据同步可能存在数秒到数分钟的延迟。设计应用架构时必须考虑到这种可能性。对于需要强实时性的场景，可以考虑结合使用 Salesforce Platform Events。
Heroku Connect 计划限制：Heroku Connect 根据不同的订阅计划，对可同步的行数 (Row Limit) 和对象数 (Table Limit) 有不同的限制。在项目初期，必须根据预估的数据量选择合适的计划，并为未来的增长留出余地。
错误处理与监控 (Error Handling and Monitoring)：当一条记录从 Heroku 同步到 Salesforce 失败时（例如，触发了 Salesforce 的验证规则），该记录在 Heroku Connect 仪表盘中会显示为 "Failed" 状态。必须建立一套流程来定期监控和处理这些同步失败的记录，否则会导致数据不一致。
数据安全 (Data Security)：同步到 Heroku Postgres 的数据脱离了 Salesforce 平台的安全模型。因此，必须确保 Heroku 应用本身以及 Postgres 数据库具有足够的安全措施，包括网络访问控制、数据加密、以及应用层面的身份验证和授权。
复杂数据结构：对于某些复杂的数据关系，如多态关系查找 (Polymorphic Lookups)，Heroku Connect 的支持可能有限或需要额外的配置。在同步复杂的对象模型之前，务必查阅官方文档并进行充分测试。

总结与最佳实践

对于 Salesforce 集成工程师而言，Heroku 和 Heroku Connect 是工具箱中不可或缺的利器。它们完美地补充了 Salesforce Platform 的能力，让我们能够构建更强大、更灵活、更具扩展性的应用程序。

最佳实践总结：

明确数据需求：在配置同步之前，仔细规划哪些对象和字段是 Heroku 应用真正需要的。避免同步不必要的数据，以节省成本和 API 调用。
优先使用单向同步：如果 Heroku 应用只需要读取 Salesforce 数据，请始终将同步方向配置为从 Salesforce 到 Heroku (Read-only)。这能显著减少 API 的消耗。
利用 Named Credentials：在 Apex 中调用 Heroku 服务时，务必使用 Named Credentials 来管理端点和认证信息。这提高了代码的安全性和可维护性。

监控先行

分离关注点 (Separation of Concerns)：让 Salesforce 专注于其核心能力——CRM 流程和数据管理。将计算密集型、面向大量用户的或需要特定技术栈的任务交由 Heroku 处理。这种架构上的分离使得整个系统更加健壮和易于维护。
考虑事件驱动架构：将 Heroku Connect 用于状态同步 (State Synchronization)，同时结合 Salesforce Platform Events 实现事件驱动 (Event-driven) 的实时通信。例如，当 Salesforce 中发生重要业务事件时，发布一个平台事件，Heroku 应用可以订阅此事件并立即做出响应，而不是等待数据同步。

通过遵循这些原则和实践，我们可以充分发挥 Salesforce 与 Heroku 结合的强大威力，为企业构建出满足未来业务发展需求的集成解决方案。

Salesforce中文网