SubmitQueryJob 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
描述¶
使用批量 API 2.0 向 Salesforce 提交查询作业。
输入要求¶
ALLOWED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
列分隔符 |
用于 CSV 作业数据的列分隔符。 |
配置模式 |
用于配置此处理器的配置模式。如果使用高级模式，则必须提供 SOQL 查询，并且无论查询的是哪个对象，处理器的状态都将仅存储上次提交的查询作业的时间戳。如果使用简单模式，则必须提供对象名称和要查询的字段，并且对于每个查询的对象，处理器的状态都将存储上次提交的查询作业的时间戳。 |
增量卸载 |
处理器是否应执行增量卸载。如果为 true，则处理器将通过对 SystemModstamp 字段使用 WHERE 子句，仅提取自上次提交查询作业以来已修改的记录。 |
行尾 |
用于 CSV 作业数据的行尾，标志着数据行的结尾。 |
对象字段 |
要为指定对象查询的字段名称的列表，以逗号分隔。 |
对象名称 |
要查询的对象的名称。 |
操作 |
要提交的查询的类型。 |
查询 |
要执行的查询。为了执行增量检索（即仅检索自上次提交查询以来添加/修改/删除的元素），该处理器提供了两个属性：${nowTs} 和 ${lastJobTimestamp}。这些占位符可以这样使用：SELECT Id FROM Account WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}。 |
结果格式 |
用于结果的格式。目前，唯一支持的值是 CSV。 |
Salesforce 客户端 |
与 APIs 交互的 Salesforce 客户端 |
状态管理¶
范围 |
描述 |
|---|---|
CLUSTER |
如果增量检索的占位符用在了查询字段中，则上次查询作业提交时间的时间戳减去 30 秒后，便将存储在该状态中。 |
关系¶
名称 |
描述 |
|---|---|
comms.failure |
如果无法提交查询作业，但可以重试该操作，则会将传入 FlowFile 路由到此关系 |
failure |
如果无法提交查询作业，则会将传入 FlowFile 路由到此关系 |
success |
成功提交查询作业后，FlowFile 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
jobId |
此作业的唯一 ID。 |
operationType |
查询的类型。 |
objectType |
正在查询的对象类型。 |
createdById |
创建作业的用户的 ID。 |
createdDate |
创建作业的 UTC 日期和时间。 |
systemModstamp |
API 上次更新作业信息的 UTC 日期和时间。 |
jobState |
作业的当前处理状态。 |
concurrencyMode |
如何处理请求。 |
contentType |
用于结果的格式。 |
apiVersion |
创建作业时使用的 API 版本。 |
lineEnding |
用于 CSV 作业数据的行尾，标志着数据行的结尾。 |
columnDelimiter |
用于 CSV 作业数据的列分隔符。 |
用例¶
使用批量 API 2.0 向 Salesforce 提交查询作业。 |