SubmitQueryJob 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
설명¶
Bulk API 2.0을 사용하여 Salesforce에 쿼리 작업을 제출합니다. SIMPLE 모드에서는 오브젝트별 상태(previousLast, currentLast 및 status)가 구성된 컨트롤러 서비스에 저장됩니다. ADVANCED 모드에서는 오브젝트 전반에서 증분 쿼리를 지원하기 위해 단일 ‘마지막’ 타임스탬프가 프로세서 범위에 저장됩니다.
입력 요구 사항¶
ALLOWED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
열 구분 기호 |
CSV 작업 데이터에 사용되는 열 구분 기호입니다. |
구성 모드 |
이 프로세서를 구성하기 위한 구성 모드입니다. 고급 모드를 사용하는 경우 SOQL 쿼리를 제공해야 하며, 프로세서의 상태는 쿼리된 오브젝트에 관계없이 마지막 쿼리 작업 제출의 타임스탬프만 저장합니다. 단순 모드를 사용하는 경우 쿼리할 오브젝트 이름과 필드를 제공해야 하며 프로세서의 상태는 쿼리된 각 오브젝트에 대한 마지막 쿼리 작업 제출의 타임스탬프를 저장합니다. |
증분 오프로드 |
프로세서가 증분 오프로드를 수행해야 하는지 여부입니다. true인 경우, 프로세서는 SystemModstamp 필드에 WHERE 절을 사용하여 마지막 쿼리 작업 제출 이후에 수정된 레코드만 가져옵니다. |
라인 끝 |
CSV 작업 데이터에 사용되는 라인 끝으로, 데이터 행의 끝을 표시합니다. |
오브젝트 필드 |
지정된 오브젝트에 대해 쿼리할 필드 이름을 쉼표로 구분한 목록입니다. |
오브젝트 이름 |
쿼리할 오브젝트의 이름입니다. |
작업 |
제출할 쿼리 유형입니다. |
쿼리 |
수행할 쿼리입니다. 증분 검색(즉, 쿼리의 마지막 제출 이후 추가/수정/삭제된 요소만 검색)을 수행하기 위해 이 프로세서는 두 가지 특성 ${nowTs} 및 ${lastJobTimestamp}를 노출합니다. 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 |
수신 FlowFile은 동일한 오브젝트에 대한 이전 작업이 여전히 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에 쿼리 작업을 제출합니다. |