FetchDatabaseMetadata 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-horizon-catalog-processors-nar
설명¶
모든 테이블에 대한 전체 데이터베이스 메타데이터를 가져와서 FlowFile로 출력합니다. 출력은 열 이름, 데이터 타입, 메타데이터 등 모든 테이블에 대한 데이터베이스 정보와 스키마 세부 정보가 포함된 JSON 배열입니다. 스키마 가져오기는 PostgreSQL, MySQL 및 SQL Server를 지원합니다. SQL Server의 경우, 이 프로세서는 적절한 권한으로 연결된 경우 액세스할 수 있는 ALL 데이터베이스에서 메타데이터를 검색할 수 있습니다. PostgreSQL 및 MySQL의 경우 연결된 데이터베이스에서 메타데이터를 검색합니다. 출력 형식(데이터베이스 오브젝트의 배열): [ { “source”: “<database_type>”, “database_name”: “<database_name>”, “schemas”: [ { “name”: “<schema_name>”, “entities”: [ { “name”: “<table_name>”, “type”: “table”, “comment”: “<table_comment>”, “total_rows”: <number_of_rows>, “columns”: [ { “name”: “<column_name>”, “comment”: “<column_comment>”, “data_type”: “<data_type>” } ], “created_on”: <epoch_millis>, “updated_on”: <epoch_millis> } ] } ] } ] 참고: SQL Server 연결의 경우 해당 연결을 통해 여러 데이터베이스에 액세스할 수 있다면 배열에는 여러 데이터베이스 오브젝트가 포함됩니다. PostgreSQL 및 MySQL의 경우 배열에는 단일 데이터베이스 오브젝트가 포함됩니다. 테이블 및 열 설명, created_on, added_on timestamps, total_rows는 데이터베이스 메타데이터에서 사용할 수 있는 경우 포함되지만, 데이터베이스 시스템에서 지원하지 않는 경우 생략해도 됩니다. 타임스탬프는 Epoch 밀리초로 표시되거나, 사용할 수 없는 경우 -1로 표시됩니다. 총 행 수는 데이터베이스 통계의 대략적인 값이나 추정 값(정확한 개수가 아님)을 나타내며 권한 또는 기타 데이터베이스별 제한으로 인해 결정할 수 없는 경우 -1로 설정됩니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
Connection Pool |
스키마 정보를 가져오는 데 사용할 연결 풀 |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFiles는 스키마 정보를 가져올 수 없는 경우 이 관계로 라우팅됩니다. |
테이블을 찾을 수 없음 |
FlowFiles는 액세스할 수 있는 데이터베이스에서 테이블을 찾을 수 없는 경우 이 관계로 라우팅됩니다. |
retryable failure |
FlowFiles는 스키마 정보 가져오기가 실패하면 이 관계로 라우팅되지만, 작업을 다시 시도하면 성공할 수 있습니다. |
성공 |
FlowFiles는 스키마 정보를 성공적으로 가져오면 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
mime.type |
application/json |
dbms.type |
데이터베이스 관리 시스템(DBMS)의 유형입니다. 예: |
database.count |
발견 및 처리된 데이터베이스 수입니다. |
schema.count |
모든 데이터베이스에서 발견된 총 스키마 수입니다. |
table.count |
모든 데이터베이스 및 스키마에서 발견된 총 테이블 수입니다. |