RunDatabricksJob
RunDatabricksJob
사전 정의된 Databricks 작업을 사용자 정의 파라미터로 실행하도록 트리거하는 OpenFlow 프로세서예요. 작업 파라미터는 동적 속성으로 설정할 수 있어요.
출처: Snowflake 문서
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
설명 (Description)
사전 정의된 Databricks 작업을 사용자 정의 파라미터로 실행하도록 트리거합니다. 작업 파라미터는 동적 속성을 사용해 설정할 수 있습니다.
태그 (Tags)
databricks, jobs, openflow
입력 요구사항 (Input Requirement)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Databricks Client | Databricks Client Service입니다. |
| Job ID | Databricks Job ID입니다. |
| Job Name | Databricks Job Name입니다. |
| Wait for Job Completion | FlowFile을 success로 전송하기 전에 Databricks 작업이 완료될 때까지 기다립니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | Databricks 실패 관계입니다. |
| success | Databricks 성공 관계입니다. |
쓰는 속성 (Writes attributes)
| 이름 (Name) | 설명 (Description) |
|---|---|
| job.run.id | 호출된 작업에 할당된 run id입니다. |
| job.result.state | 호출된 작업의 결과 상태입니다. |
| error.code | 오류가 발생한 경우 SQL 문에 대한 오류 코드입니다. |
| error.message | 오류가 발생한 경우 SQL 문에 대한 오류 메시지입니다. |