精通 Salesforce Connect：外部对象实时数据集成权威指南

背景与应用场景

作为一名 Salesforce 架构师，我在设计企业级解决方案时，面临的核心挑战之一便是如何优雅地处理“数据孤岛”问题。现代企业的关键数据往往散布在不同的系统中：核心业务数据可能在 SAP 或 Oracle 等 ERP 系统中，客户支持历史可能在某个本地部署的遗留系统中，而产品目录则由一个专门的 PIM (Product Information Management) 系统管理。将所有数据都通过 ETL (Extract, Transform, Load - 提取、转换、加载) 的方式同步到 Salesforce 平台，不仅成本高昂，还会带来数据延迟、存储成本增加以及维护复杂性等一系列问题。

在许多业务场景下，用户需要的仅仅是“查看”或“轻量级操作”这些外部数据，而不是拥有和管理它们。例如，销售代表在客户（Account）页面上，希望能够实时查看该客户的最新订单历史和发货状态，而这些数据源自公司的 ERP 系统。如果采用传统的 ETL 方式，这些数据可能是数小时甚至一天前的，无法满足实时性的要求。

Salesforce Connect 正是为解决这类问题而生的数据集成利器。它是一种采用数据虚拟化 (Data Virtualization) 或数据联邦 (Data Federation) 思想的解决方案。简单来说，它允许您在 Salesforce 中创建一种特殊的对象——External Object (外部对象)，这种对象的数据并不实际存储在 Salesforce 的数据库中，而是实时地从外部数据源查询而来。对于 Salesforce 用户而言，这些外部对象的界面和操作体验（如在列表视图、页面布局、甚至是 SOQL 查询中）与标准的自定义对象几乎没有区别，从而实现了无缝的集成体验。

典型的应用场景包括：

360度客户视图：在客户详情页上直接展示来自 ERP 系统的订单历史、发票信息和物流状态。
主数据管理 (MDM)：当企业有统一的客户或产品主数据中心时，Salesforce 可以通过 Salesforce Connect 实时引用这些主数据，确保数据的一致性，避免冗余存储。
数据合规性：对于某些因法律法规或隐私政策而无法存储在云端的敏感数据（如医疗记录、金融交易细节），可以通过 Salesforce Connect 进行只读访问，满足业务需求的同时确保合规。
快速原型验证：在项目初期，可以快速连接到一个外部数据源来验证业务流程，而无需花费大量时间构建复杂的数据同步逻辑。

原理说明

Salesforce Connect 的核心在于其强大的适配器框架（Adapter Framework）。当用户或系统在 Salesforce 中对一个外部对象进行操作时（例如，打开一个记录详情页或执行一个 SOQL 查询），Salesforce 平台会识别出这是一个外部对象请求，并将其转交给相应的适配器。适配器负责将 Salesforce 的请求（如 SOQL）“翻译”成外部数据源能够理解的协议和查询语言（如 OData URL），然后将外部系统的响应数据“翻译”回 Salesforce 的标准格式，最终呈现给用户。

Salesforce Connect 主要提供以下几种适配器：

OData 2.0 & OData 4.0/4.01 Adapter: 这是最常用、最标准化的连接方式。OData (Open Data Protocol - 开放数据协议) 是一个基于 RESTful API 的 OASIS 标准，它定义了一套构建和使用可查询、可互操作的 RESTful API 的最佳实践。如果您的外部系统（如 SAP, SharePoint, Microsoft Dynamics）已经提供了 OData 端点，那么配置 Salesforce Connect 将会非常简单，只需提供 OData 服务的 URL 和认证信息即可。
Cross-Org Adapter: 这种适配器专门用于连接另一个 Salesforce Org。它可以让您在一个 Org 中实时访问和操作另一个 Org 的数据，对于拥抱多 Org 战略的企业来说非常有用。
Apex Custom Adapter: 这是最灵活也最强大的适配器。当您的外部数据源没有提供标准的 OData 接口，而是提供了自定义的 REST 或 SOAP API 时，您可以通过编写 Apex 代码来创建自己的适配器。这使得 Salesforce Connect 几乎可以连接到任何拥有 API 的系统。您需要实现 Salesforce 定义的 `DataSource.Provider` 和 `DataSource.Connection` 接口，在代码中自定义数据查询、身份验证和功能声明的逻辑。

无论使用哪种适配器，数据的流动路径都是一致的：用户操作 -> Salesforce 平台 -> Salesforce Connect 适配器 -> 外部数据源 API -> Salesforce Connect 适配器 -> Salesforce 平台 -> 用户界面。这个实时双向翻译的过程，是 Salesforce Connect 实现数据虚拟化的关键。

示例代码

对于架构师来说，理解 Apex Custom Adapter (Apex 自定义适配器) 的能力至关重要，因为它揭示了 Salesforce Connect 的最大潜力。以下是一个来自 Salesforce 官方文档的简化示例，它展示了如何创建一个自定义适配器来连接到一个虚构的文件存储系统。我们将重点关注其核心方法的实现。

首先，您需要定义一个 `Provider` 类，它负责声明适配器的功能和创建连接实例。

// DataSource.Provider 类用于声明适配器的功能和认证方式
public class FileDataSourceProvider extends DataSource.Provider {
    // 声明适配器支持哪些功能，例如，这里我们声明支持“行级搜索”
    override public List<DataSource.Capability> getCapabilities() {
        List<DataSource.Capability> capabilities = new List<DataSource.Capability>();
        capabilities.add(DataSource.Capability.ROW_QUERY);
        capabilities.add(DataSource.Capability.SEARCH);
        return capabilities;
    }

    // 声明适配器支持的认证方式，这里是匿名访问
    override public List<DataSource.AuthenticationCapability> getAuthenticationCapabilities() {
        List<DataSource.AuthenticationCapability> capabilities = new List<DataSource.AuthenticationCapability>();
        capabilities.add(DataSource.AuthenticationCapability.ANONYMOUS);
        return capabilities;
    }

    // 当 Salesforce 需要与外部系统交互时，会调用此方法来获取一个连接实例
    override public DataSource.Connection getConnection(DataSource.ConnectionParams connectionParams) {
        return new FileDataSourceConnection();
    }
}

接下来，是 `Connection` 类的实现，它包含了处理数据操作的核心逻辑，比如查询（query）和同步（sync）。

// DataSource.Connection 类负责处理实际的数据交互逻辑
public class FileDataSourceConnection extends DataSource.Connection {
    // sync() 方法用于发现外部数据源的“表”结构，并将其同步为 Salesforce 的外部对象定义
    override public List<DataSource.Table> sync() {
        // 在真实场景中，这里会调用外部系统的 API 来获取所有可用的数据表（或实体）
        // 然后为每一个外部表创建一个 DataSource.Table 对象
        DataSource.Table table = DataSource.Table.get('files', 'Name', null);
        
        // 定义外部表的“列”，并映射为外部对象的字段
        // DataSource.Column.text(列名, 长度)
        table.columns.add(DataSource.Column.text('Title', 255));
        table.columns.add(DataSource.Column.url('DownloadUrl'));
        
        return new List<DataSource.Table>{table};
    }

    // query() 方法是核心，它负责处理 SOQL 查询
    // 当用户或代码执行一个针对此外部对象的 SOQL 时，此方法被调用
    override public DataSource.QueryResults query(DataSource.QueryContext context) {
        // 创建一个 DataSource.QueryResults 对象来存放查询结果
        DataSource.QueryResults results = new DataSource.QueryResults();
        
        // context 对象包含了原始的 SOQL 查询信息，如查询的表、列、过滤条件等
        // 在真实场景中，您需要解析 context，构建对外部系统的 API 调用
        // 例如：String apiUrl = 'https://api.myfiles.com/search?q=' + context.queryMoreToken;
        // HttpResponse response = makeApiCall(apiUrl);
        // List<Map<String, Object>> responseData = parseResponse(response);

        // 以下为模拟数据
        List<Map<String, Object>> responseData = new List<Map<String, Object>>();
        Map<String, Object> row1 = new Map<String, Object>();
        row1.put('Name', 'doc-001'); // 外部 ID
        row1.put('Title', 'Q1-Financials.pdf');
        row1.put('DownloadUrl', 'https://example.com/doc-001');
        responseData.add(row1);

        // 将从外部系统获取的数据行添加到结果集中
        results.rows.addAll(responseData);
        
        return results;
    }
}

注意事项

虽然 Salesforce Connect 功能强大，但作为架构师，我们必须清醒地认识到它的局限性和适用边界，避免在不合适的场景中滥用它。

API 调用限制：这是最关键的制约因素。对外部对象的每一次数据访问（包括加载记录、执行查询、运行报表）都会消耗一个 Salesforce Callout。在高频访问场景下，例如将外部对象放在一个被大量用户访问的首页仪表盘上，会迅速耗尽组织的每日 API Callout 限额。
性能依赖：Salesforce 页面的加载速度直接取决于外部数据源 API 的响应速度。如果外部系统响应缓慢（高延迟），Salesforce 的用户体验将变得非常糟糕。因此，外部系统的性能和稳定性是项目成功的先决条件。
功能限制：外部对象不支持 Salesforce 平台的所有功能。例如：
- 它们不支持标准的记录所有权 (Ownership) 和共享规则 (Sharing Rules)。访问权限主要由外部数据源的认证设置和外部对象的简档权限控制。
- 通常不支持 Apex Triggers 和大部分自动化工具（如 Record-Triggered Flows）。虽然平台事件和一些新功能正在弥补这部分差距，但原生支持依然非常有限。
- 不支持大多数字段类型，且在关系（Relationship）上有限制，仅支持查找（Lookup）、外部查找（External Lookup）和间接查找（Indirect Lookup）。
报表和分析：虽然外部对象可以用于报表，但复杂的报表（特别是涉及大量数据聚合和分组的）性能可能不佳，因为每次刷新报表都需要实时从外部系统拉取数据。它不适合大规模的数据仓库和商业智能（BI）场景。
SOQL/SOSL 限制：并非所有的 SOQL 查询子句都受支持，这取决于适配器的能力声明（`getCapabilities()`）。例如，复杂的 `GROUP BY` 或 `HAVING` 子句通常不受支持。SOSL（Salesforce Object Search Language）则完全不支持外部对象。
错误处理：如果外部系统宕机或 API 出现故障，Salesforce 中的用户将会直接看到错误信息。必须在架构设计中考虑外部系统的可用性，并建立相应的监控和告警机制。

总结与最佳实践

Salesforce Connect 是一个战术性的、用于特定场景的集成工具，而非一个可以替代所有 ETL 过程的银弹。作为架构师，我们需要根据业务需求的实时性、数据量、交互复杂度和外部系统的能力，来决定何时采用它。

最佳实践建议：

明确使用原则：当您需要实时、低频次、小批量地访问外部数据，并且不希望或不需要将数据副本存储在 Salesforce 中时，Salesforce Connect 是绝佳选择。遵循“按需查看，而非全量复制” (View on demand, don't copy everything) 的原则。
采用混合集成模式 (Hybrid Integration)：在复杂的企业架构中，最佳方案往往是混合模式。使用 Salesforce Connect 满足实时性要求高的“热”数据访问场景；同时，对于需要进行复杂分析、报表或触发复杂业务流程的“冷”数据，仍然采用传统的 ETL/ELT 工具（如 MuleSoft, Informatica, 或 Salesforce Data Pipelines）进行定期的批量同步。
优先选择标准适配器：如果外部系统支持 OData，请务必优先使用 OData 适配器。这能极大地降低开发和维护成本。仅在无法使用标准适配器时，才投入资源开发 Apex 自定义适配器。
性能优先设计：在设计与外部系统的集成时，必须将性能放在首位。确保外部 API 支持分页 (Pagination)、服务端过滤 (Server-side Filtering) 和排序 (Sorting)，并在 Apex 自定义适配器中充分利用这些能力，以减少数据传输量和处理时间。
做好治理和监控：密切监控 API Callout 的消耗情况，为外部数据源设置合理的超时限制，并与外部系统的所有者建立清晰的服务水平协议 (SLA)。

总而言之，Salesforce Connect 通过数据虚拟化的方式，为 Salesforce 平台提供了一种轻量级、实时且强大的数据集成能力。正确地理解其原理、优势与局限，并将其放置在企业整体数据架构的合适位置，它将成为我们构建无缝、高效且可扩展的 Salesforce 解决方案的有力武器。

Salesforce Einstein AI 编程实践：开发者视角下的智能预测

九月 15, 2025

阅读全文

Salesforce中文网