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.AbortQueryJob
  • com.snowflake.openflow.runtime.processors.salesforce.DeleteQueryJob
  • com.snowflake.openflow.runtime.processors.salesforce.GetQueryJobResult
  • com.snowflake.openflow.runtime.processors.salesforce.SubmitQueryJob

더 알아보기 (Learn more)