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로 설정됩니다.

태그

database, metadata, schema, table

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

Connection Pool

스키마 정보를 가져오는 데 사용할 연결 풀

관계

이름

설명

실패

FlowFiles는 스키마 정보를 가져올 수 없는 경우 이 관계로 라우팅됩니다.

테이블을 찾을 수 없음

FlowFiles는 액세스할 수 있는 데이터베이스에서 테이블을 찾을 수 없는 경우 이 관계로 라우팅됩니다.

retryable failure

FlowFiles는 스키마 정보 가져오기가 실패하면 이 관계로 라우팅되지만, 작업을 다시 시도하면 성공할 수 있습니다.

성공

FlowFiles는 스키마 정보를 성공적으로 가져오면 이 관계로 라우팅됩니다.

Writes 특성

이름

설명

mime.type

application/json

dbms.type

데이터베이스 관리 시스템(DBMS)의 유형입니다. 예: POSTGRESQL

database.count

발견 및 처리된 데이터베이스 수입니다.

schema.count

모든 데이터베이스에서 발견된 총 스키마 수입니다.

table.count

모든 데이터베이스 및 스키마에서 발견된 총 테이블 수입니다.