SubmitQueryJob 2025.5.31.15¶
번들¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
설명¶
Bulk 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 Client |
APIs 와 상호 작용할 수 있는 Salesforce Client |
상태 관리¶
범위 |
설명 |
|---|---|
CLUSTER |
쿼리 필드에 증분 검색을 위한 자리 표시자를 사용하는 경우, 마지막 쿼리 작업 제출 시간의 타임스탬프에서 30초를 뺀 값이 상태에 저장됩니다. |
관계¶
이름 |
설명 |
|---|---|
comms.failure |
수신 FlowFile 은 쿼리 작업을 제출할 수 없지만, 작업을 다시 시도할 수 있는 경우 이 관계로 라우팅됩니다 |
실패 |
수신 FlowFile 은 쿼리 작업을 제출할 수 없는 경우 이 관계로 라우팅됩니다 |
성공 |
쿼리 작업이 성공적으로 제출되면 FlowFile 은 이 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
jobId |
이 작업을 위한 고유한 ID 입니다. |
operationType |
쿼리 유형입니다. |
objectType |
쿼리 중인 오브젝트 유형입니다. |
createdById |
작업을 생성한 사용자의 ID 입니다. |
생성된 날짜 |
작업이 생성된 UTC 날짜와 시간입니다. |
systemModstamp |
API 가 마지막으로 작업 정보를 업데이트한 UTC 날짜 및 시간입니다. |
jobState |
작업의 현재 처리 상태입니다. |
concurrencyMode |
요청이 처리되는 방식입니다. |
contentType |
결과에 사용할 형식입니다. |
apiVersion |
작업이 생성된 API 버전입니다. |
lineEnding |
CSV 작업 데이터에 사용되는 라인 끝으로, 데이터 행의 끝을 표시합니다. |
columnDelimiter |
CSV 작업 데이터에 사용되는 열 구분 기호입니다. |
사용 사례¶
Bulk API 2.0을 사용하여 Salesforce에 쿼리 작업을 제출합니다. |