GetQueryJobStatus 프로세서
GetQueryJobStatus 프로세서
Openflow의 GetQueryJobStatus 프로세서는 Salesforce Bulk API 2.0을 사용해 Query Job의 상태를 가져오는 프로세서예요.
출처: Snowflake 문서
본문
기능 — 일반 공급 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있습니다.
Bundle
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
설명
Salesforce에서 Bulk API 2.0을 사용해 Query Job의 상태를 가져옵니다.
태그
bulk, job, preview, query, salesforce, status
입력 요구사항
필수 (REQUIRED)
민감한 동적 속성 지원
false
속성
| 이름 | 설명 |
|---|---|
| Job ID | 상태를 확인하는 작업(job)의 ID입니다. |
| Salesforce Client | API와 상호 작용하는 Salesforce 클라이언트입니다. |
관계
| 이름 | 설명 |
|---|---|
| comms.failure | Query Job 상태를 가져올 수 없지만 작업을 재시도할 수 있는 경우 FlowFile이 이 관계로 라우팅됩니다. |
| failure | Query Job 상태를 가져올 수 없는 경우 FlowFile이 이 관계로 라우팅됩니다. |
| job.aborted | Query Job이 중단된 경우 FlowFile이 이 관계로 라우팅됩니다. |
| job.completed | Query Job이 완료된 경우 FlowFile이 이 관계로 라우팅됩니다. |
| job.failed | Query Job이 실패한 경우 FlowFile이 이 관계로 라우팅됩니다. |
| wait | Query Job이 처리 대기열에 있거나 진행 중인 경우 FlowFile이 이 관계로 라우팅됩니다. |
쓰기 속성
| 이름 | 설명 |
|---|---|
| jobState | 작업의 현재 처리 상태입니다. |
| systemModstamp | API가 작업 정보를 마지막으로 업데이트한 UTC 날짜 및 시간입니다. |
| numberRecordsProcessed | 이 작업에서 처리된 레코드 수입니다. |
| retries | Salesforce가 작업 결과 저장을 시도한 횟수입니다. 반복적인 시도는 잠금 경합과 같은 문제를 나타냅니다. |
| totalProcessingTime | 작업 처리에 걸린 밀리초 수입니다. |
| isPkChunkingSupported | 조회 대상 객체에 대해 PK 청킹이 지원되는지(true) 아닌지(false) 여부입니다. |
참고 항목
com.snowflake.openflow.runtime.processors.salesforce.AbortQueryJobcom.snowflake.openflow.runtime.processors.salesforce.DeleteQueryJobcom.snowflake.openflow.runtime.processors.salesforce.GetQueryJobResultcom.snowflake.openflow.runtime.processors.salesforce.SubmitQueryJob