SubmitQueryJob 2025.10.2.19¶

捆绑包¶

com.snowflake.openflow.runtime | runtime-salesforce-processors-nar

描述¶

使用批量 API 2.0 向 Salesforce 提交查询作业。在 SIMPLE 模式下，每个对象的状态 (previousLast/currentLast and status) 存储在配置的控制器服务中。在 ADVANCED 模式下，单个 'last' 时间戳存储在处理器范围内，以支持跨对象的增量查询。

标签¶

bulk, job, preview, query, salesforce

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
列分隔符	用于 CSV 作业数据的列分隔符。
配置模式	The configuration mode for configuring this processor. If using advanced mode, the SOQL query has to be provided and the processor 's state will only store the timestamp of the last query job submission regardless of the object queried. If using simple mode, the object name and the fields to be queried have to be provided and the processor's state will store the timestamp of the last query job submission for each object queried.
增量卸载	Whether the processor should perform incremental offload. If true, the processor will only fetch the records that have been modified since the last query job submission by using a WHERE clause on the SystemModstamp field.
行尾	用于 CSV 作业数据的行尾，标志着数据行的结尾。
对象字段	要为指定对象查询的字段名称的列表，以逗号分隔。
对象名称	要查询的对象的名称。
操作	要提交的查询的类型。
查询	The query to be performed. In order to perform incremental retrieval (ie. only the added/modified/deleted elements since the last submission of the query are retrieved), this processor exposes two attributes: ${nowTs} and ${lastJobTimestamp}. It is possible to use those placeholders like SELECT Id FROM Account WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}.
结果格式	用于结果的格式。目前，唯一支持的值是 CSV。
Salesforce 批量任务状态服务	控制器服务，用于存储每种对象类型的批量作业状态（在 SIMPLE 模式中使用）。在 ADVANCED 模式下，处理器在处理器状态下存储一个 'last' 时间戳。
Salesforce 客户端	与 APIs 交互的 Salesforce 客户端

状态管理¶

范围	描述
CLUSTER	如果增量检索的占位符用在了查询字段中，则上次查询作业提交时间的时间戳减去 30 秒后，便将存储在该状态中。

关系¶

名称	描述
comms.failure	如果无法提交查询作业，但可以重试该操作，则会将传入 FlowFile 路由到此关系
failure	如果无法提交查询作业，则会将传入 FlowFile 路由到此关系
in.progress	An incoming FlowFile is routed to this relationship when a previous job for the same object is still IN_PROGRESS
success	成功提交查询作业后，FlowFile 将路由到此关系

写入属性¶

名称	描述
jobId	此作业的唯一 ID。
operationType	查询的类型。
objectType	正在查询的对象类型。
createdById	创建作业的用户的 ID。
createdDate	创建作业的 UTC 日期和时间。
systemModstamp	API 上次更新作业信息的 UTC 日期和时间。
jobState	作业的当前处理状态。
concurrencyMode	如何处理请求。
contentType	用于结果的格式。
apiVersion	创建作业时使用的 API 版本。
lineEnding	用于 CSV 作业数据的行尾，标志着数据行的结尾。
columnDelimiter	用于 CSV 作业数据的列分隔符。
nowTs	用于构造查询任务的 WHERE 中时间范围的上限。
lastJobTimestamp	用于构造查询任务的 WHERE 中时间范围的下限。

用例¶

使用批量 API 2.0 向 Salesforce 提交查询作业。