289.4. 支持的 Salesforce API

对于 operationName，您可以使用以下内容：

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

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

Bulk 2.0 API 对原始 Bulk API 提供了简化的模型。使用它来快速将大量数据加载到 Salesforce 中，或者从 Salesforce 中查询大量数据。数据必须以 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 来创建作业批处理。消息中的正文必须包含可转换为 InputStream （通常是来自文件的 UTF-8 CSV 或 XML 内容）的正文，以及作业内容类型的作业和 'contentType' 的标头字段 'jobId'，可以是 XML、CSV、ZIP_XML 或 ZIP_CSV。put 消息正文将包含 BatchInfo on success，或抛出 SalesforceException on 错误。

...to("salesforce:createBatchJob")..

消费者端点可以使用以下 sytax 进行流传输端点，来在 create/update 上接收 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，带有 key-value datacategories-wagonin，该情况需要设置为 sObjectName 的 API 名称，或使用事件的适当类名称扩展类。

例如，使用 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" + String.valueOf(in.getHeader(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" + String.valueOf(in.getHeader(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);