SubmitQueryJob 2025.10.2.19¶

번들¶

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

설명¶

Bulk API 2.0을 사용하여 Salesforce에 쿼리 작업을 제출합니다. SIMPLE 모드에서는 오브젝트별 상태(previousLast, currentLast 및 status)가 구성된 컨트롤러 서비스에 저장됩니다. ADVANCED 모드에서는 오브젝트 전반에서 증분 쿼리를 지원하기 위해 단일 ‘마지막’ 타임스탬프가 프로세서 범위에 저장됩니다.

태그¶

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 모드에서 프로세서는 프로세서 상태의 단일 ‘마지막’ 타임스탬프를 저장합니다.
Salesforce Client	APIs 와 상호 작용할 수 있는 Salesforce Client

상태 관리¶

범위	설명
CLUSTER	쿼리 필드에 증분 검색을 위한 자리 표시자를 사용하는 경우, 마지막 쿼리 작업 제출 시간의 타임스탬프에서 30초를 뺀 값이 상태에 저장됩니다.

관계¶

이름	설명
comms.failure	수신 FlowFile 은 쿼리 작업을 제출할 수 없지만, 작업을 다시 시도할 수 있는 경우 이 관계로 라우팅됩니다
실패	수신 FlowFile 은 쿼리 작업을 제출할 수 없는 경우 이 관계로 라우팅됩니다
in.progress	An incoming FlowFile is routed to this relationship when a previous job for the same object is still IN_PROGRESS
성공	쿼리 작업이 성공적으로 제출되면 FlowFile 은 이 관계로 라우팅됩니다

Writes 특성¶

이름	설명
jobId	이 작업을 위한 고유한 ID 입니다.
operationType	쿼리 유형입니다.
objectType	쿼리 중인 오브젝트 유형입니다.
createdById	작업을 생성한 사용자의 ID 입니다.
생성된 날짜	작업이 생성된 UTC 날짜와 시간입니다.
systemModstamp	API 가 마지막으로 작업 정보를 업데이트한 UTC 날짜 및 시간입니다.
jobState	작업의 현재 처리 상태입니다.
concurrencyMode	요청이 처리되는 방식입니다.
contentType	결과에 사용할 형식입니다.
apiVersion	작업이 생성된 API 버전입니다.
lineEnding	CSV 작업 데이터에 사용되는 라인 끝으로, 데이터 행의 끝을 표시합니다.
columnDelimiter	CSV 작업 데이터에 사용되는 열 구분 기호입니다.
nowTs	쿼리 작업을 구성하기 위해 WHERE 절에 사용되는 시간 범위의 상한입니다.
lastJobTimestamp	쿼리 작업을 구성하기 위해 WHERE 절에 사용되는 시간 범위의 하한입니다.

사용 사례¶

Bulk API 2.0을 사용하여 Salesforce에 쿼리 작업을 제출합니다.