43.7. 支持的 Salesforce API

您可以将以下内容用于 operationName ：

例如，以下制作者端点使用 upsertSObject API，并将 sObjectIdName 参数指定 'Name' 作为外部 id 字段。请求消息正文应该是使用 maven 插件生成的 SObject DTO。如果更新了现有记录，或者新记录 ID 为 id，则响应消息为 null，或者在创建新对象时出现错误列表。

...to("salesforce:upsertSObject?sObjectIdName=Name")...

Bulk 2.0 API 在原始 Bulk API 上有一个简化的模型。使用它来快速将大量数据加载到 Netavark 中，或者查询大量数据 from of sales。数据必须以 CSV 格式提供。Bulk 2.0 的最低 API 版本是 v41.0。Bulk Queries 的最小 API 版本为 v47.0。以下 DTO 类来自 org.apache.camel.component.salesforce.api.dto.bulkv2 软件包。支持以下操作：

制作者端点可以使用以下 API：支持所有作业数据格式，即 xml、csv、zip/xml 和 zip/csv。
路由必须全部使用请求和响应。通常，请求会像 CSV 文件一样，一些流源
，响应也可能被保存到与请求关联的文件中。

您可以将以下内容用于 operationName ：

例如，以下制作者端点使用 createBatch API 来创建作业 Batch：in 消息必须包含可转换为 InputStream （通常是 UTF-8 CSV 或 XML 内容）和标题字段 'jobId' 的正文，以及作业内容类型的 'contentType'，可以是 XML、CSV、JZ_XML 或 ZIP_CSV。put 消息正文将包含 BatchInfo 成功，或抛出 SalesforceException 错误。

...to("salesforce:createBatch")..

消费者端点可以使用以下语法在创建/更新时接收 Salesforce 通知。

创建并订阅一个主题

from("salesforce:CamelTestTopic?notifyForFields=ALL&notifyForOperations=ALL&sObjectName=Merchandise__c&updateTopic=true&sObjectQuery=SELECT Id, Name FROM Merchandise__c")...

订阅现有主题

from("salesforce:CamelTestTopic&sObjectName=Merchandise__c")...

要发送平台事件，请使用 createSObject 操作。并设置消息正文可以是 JSON 字符串或 InputStream，带有键-值 data network- 软件仓库，在这种情况下 sObjectName 需要设置为事件的 API 名称，或使用适当的类名称从 AbstractDTOBase 进行扩展。

例如，使用 DTO：

class Order_Event__e extends AbstractDTOBase {
  @JsonProperty("OrderNumber")
  private String orderNumber;
  // ... other properties and getters/setters
}

from("timer:tick")
    .process(exchange -> {
        final Message in = exchange.getIn();
        String orderNumber = "ORD" + exchange.getProperty(Exchange.TIMER_COUNTER);
        Order_Event__e event = new Order_Event__e();
        event.setOrderNumber(orderNumber);
        in.setBody(event);
    })
    .to("salesforce:createSObject");

或使用 JSON 事件数据：

from("timer:tick")
    .process(exchange -> {
        final Message in = exchange.getIn();
        String orderNumber = "ORD" + exchange.getProperty(Exchange.TIMER_COUNTER);
        in.setBody("{\"OrderNumber\":\"" + orderNumber + "\"}");
    })
    .to("salesforce:createSObject?sObjectName=Order_Event__e");

要接收平台事件，使用带有前缀 event/（或 / event/ ）的 API 事件的使用者端点，例如：Salesforce :events/Order_Event_e。从该端点消耗的处理器将分别收到 org.apache.camel.component.salesforce.api.dto.PlatformEvent 对象或 org.cometd.bayeux.Message，具体取决于正文中的 rawPayload 为 false 或 true。

例如，使用最简单的形式来消耗一个事件：

PlatformEvent event = consumer.receiveBody("salesforce:event/Order_Event__e", PlatformEvent.class);

一次，可以将 Salesforce 配置为发出通知以记录所选对象的记录更改。另一方面，Camel Salesforce 组件可能会响应此类通知，允许实例 将这些更改同步到外部系统。

可以通过订阅频道在 Camel 路由的 from ("Salesforce:XXX") 子句中指定感兴趣的通知，例如：

from("salesforce:data/ChangeEvents?replayId=-1").log("being notified of all change events")
from("salesforce:data/AccountChangeEvent?replayId=-1").log("being notified of change events for Account records")
from("salesforce:data/Employee__ChangeEvent?replayId=-1").log("being notified of change events for Employee__c custom object")

根据正文中的 rawPayload 为 false 或 true，收到的消息包含 java.util.Map<String,Object > 或 org.cometd.bayeux.Message。CamelSalesforceChangeType 标头的值可以是 CREATE、UPDATE、DELETE 或 UNDELETE 之一。

有关如何使用 Camel Salesforce 组件更改数据捕获功能的更多详细信息，请参阅 ChangeEventsConsumerIntegrationTest。

Salesforce 开发人员指南 非常适合更好地了解如何实施更改数据捕获应用程序。更改事件正文字段的动态性质，高级复制步骤以及安全注意事项可能会值得关注。