ListUnityCatalogDirectory
ListUnityCatalogDirectory
Unity Catalog 디렉터리의 파일 이름을 나열하고 해당 파일 이름을 담은 새 FlowFile을 출력하는 프로세서예요. Databricks Unity Catalog의 디렉터리 내용을 조회할 때 사용해요.
출처: Snowflake 문서
본문
기능 — 일반 제공(Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.
Bundle
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
설명 (Description)
Unity Catalog 디렉터리의 파일 이름을 나열하고 파일 이름을 담은 새 FlowFile을 출력해요.
태그 (Tags)
databricks, openflow, unity catalog
입력 요구사항 (Input Requirement)
없음
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| Property | Description |
|---|---|
| Databricks Client | Databricks Client Service예요. |
| Include Directories | 생성되는 FlowFiles에 디렉터리를 포함할지 여부예요. |
| Recursive Directory Listing | 하위 디렉터리의 파일을 재귀적으로 나열할지 여부예요. |
| Unity Catalog Directory Path | Unity Catalog 디렉터리 경로예요. 예: /Volumes/catalog/schema/volume_name/directory |
관계 (Relationships)
| Name | Description |
|---|---|
| failure | Databricks 실패 관계예요. |
| original | 처리에 성공하면 원본 FlowFile이 이 관계로 연결돼요. |
| success | Databricks 성공 관계예요. |
쓰기 속성 (Writes attributes)
| Name | Description |
|---|---|
| filename | Unity Catalog 파일 또는 디렉터리의 기본 파일 이름이에요. |
| path | Unity Catalog 파일 또는 디렉터리를 포함하는 상위 디렉터리 경로예요. |
| absolute.path | Unity Catalog 파일 또는 디렉터리의 전체 경로예요. |
| uc.resourceType | Unity Catalog 리소스의 유형으로, ‘file’ 또는 ‘directory’예요. |
| uc.size | Unity Catalog 파일의 크기예요. |
| uc.lastModifiedTime | Unity Catalog 파일의 마지막 수정 시간으로, UTC 기준 epoch 이후 밀리초 단위예요. |
| error.code | 오류가 발생한 경우 SQL 문에 대한 오류 코드예요. |
| error.message | 오류가 발생한 경우 SQL 문에 대한 오류 메시지예요. |