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)의 유형입니다. 예: |
primary.key.count |
소스 테이블의 기본 키 수입니다 |
column.count |
소스 테이블의 열 수입니다 |