FetchSourceTableSchema 2025.5.31.15

번들

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

설명

데이터베이스의 지정된 테이블에 대한 테이블 스키마(즉, 열 이름, 데이터 타입 등)를 가져와 데이터 타입을 Snowflake 호환 타입으로 변환합니다.스키마는 FlowFile 내용에 JSON 오브젝트로 { “columns”: [ { “name”: “<columnName>”, “type”: “<snowflakeType>”, “nullable”: <true|false>, “scale”: <scale>, “precision”: <precision> }, … ], “primaryKeys”: [“<primaryKey1>”, “<primaryKey2>”, …]} 같은 형식으로 기록됩니다.

태그

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

Column Filter Service

원하지 않는 열을 필터링하는 데 사용할 열 필터 서비스를 지정합니다

Connection Pool

소스 테이블 스키마를 가져오는 데 사용할 연결 풀입니다

Schema Name

소스 테이블이 저장된 스키마의 이름입니다

테이블 이름

소스 테이블의 이름입니다

관계

이름

설명

실패

FlowFiles 은 소스 테이블의 스키마를 가져올 수 없는 이벤트 발생 시 이 관계로 라우팅됩니다

성공

FlowFiles 은 소스 테이블의 스키마를 성공적으로 가져올 때 이 관계로 라우팅됩니다

table not found

FlowFiles 은 소스 테이블이 존재하지 않을 때 이 관계로 라우팅됩니다

Writes 특성

이름

설명

mime.type

application/json

dbms.type

소스 테이블이 저장된 데이터베이스 관리 시스템(DBMS)의 유형입니다. 예: POSTGRESQL

primary.key.count

소스 테이블의 기본 키 수입니다

column.count

소스 테이블의 열 수입니다