PutSalesforceObject Processor

类型全限定名：cn.org.acal.lynxus.processors.salesforce.PutSalesforceObject

所属 Bundle：cn.org.acal.lynxus:lynxus-salesforce-nar:2.11.8

描述

为指定的 Salesforce sObject 创建新记录。 Salesforce 对象的类型必须在输入FlowFile的“objectType”属性中设置。该处理器无法更新现有记录。

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Salesforce Instance URL			Salesforce 实例的 URL，包括没有附加路径信息的域，例如 https://MyDomainName.my.salesforce.com 支持表达式语言：是（仅使用环境/系统变量求值）
API Version	`54.0`		附加到 services/data 路径后 URL 的 Salesforce REST API 版本号。有关支持的版本，请参阅 Salesforce 文档支持表达式语言：是（仅使用环境/系统变量求值）
Read Timeout	`15 s`		从 Salesforce REST API 读取响应所允许的最长时间支持表达式语言：是（仅使用环境/系统变量求值）
OAuth2 Access Token Provider		控制器服务 API： `OAuth2AccessTokenProvider` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	提供 OAuth2 访问令牌以使用 HTTP 授权标头进行身份验证的服务
Record Reader		控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于解析传入数据并确定数据 Schema 的控制器服务

关系 (Relationships)

名称	描述	自动终止
`failure`	对于由于执行错误而创建的 FlowFiles。	否
`success`	对于成功执行后创建的 FlowFiles。	否

读取的 FlowFile 属性

名称	描述
`objectType`	要上传记录的 Salesforce 对象类型。例如 Account、Contact、Campaign。

写入的 FlowFile 属性

名称	描述
`error.message`	Salesforce 返回的错误消息。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

另请参阅

QuerySalesforceObject

详细说明

PutSalesforceObject

说明

Salesforce 中的对象是数据库表，其行称为记录，列称为字段。 PutSalesforceObject 在 Salesforce 对象中创建新的记录。 Salesforce 对象必须设置为传入 FlowFile 的 "objectType" Attribute。对象类型和元数据参见 Salesforce 文档。该 Processor 利用 Lynxus 基于记录的处理方式，支持任意输入格式。

示例

如果 "objectType" 设为 "Account"，下面的 JSON 输入会在 Account 对象中创建两条记录，名称分别为 "SampleAccount1" 和 "SampleAccount2"。

[
  {
    "name": "SampleAccount1",
    "phone": "1111111111",
    "website": "www.salesforce1.com",
    "numberOfEmployees": "100",
    "industry": "Banking"
  },
  {
    "name": "SampleAccount2",
    "phone": "22222222",
    "website": "www.salesforce2.com",
    "numberOfEmployees": "200",
    "industry": "Banking"
  }
]

PutSalesforceObject