FetchTableSnapshot 2025.5.31.15¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
데이터베이스에서 테이블의 스냅샷을 가져옵니다. 스냅샷은 테이블의 기본 키 열을 사용하여 일괄적으로 행을 가져오는 방식으로 증분적으로 가져옵니다. 기본 키가 없는 테이블 복제는 지원되지 않습니다. 스냅샷은 지정된 Record Writer 형식으로 FlowFile 에 기록됩니다. 입력 FlowFile 은 { “columns”: [{ “name”: “<column name>”, “type”: “<column type>” }, { “name”: “<column name>”, “type”: “<column type>” }, … ], “primaryKeys”: [“<첫 번째 기본 키 열의 이름>”, “<두 번째 기본 키 열의 이름>”, …]} 형식의 테이블 스키마의 JSON 표현으로 구성될 것으로 예상됩니다. 스키마에 지정된 열만 테이블에서 가져옵니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
---|---|
Connection Pool |
데이터베이스 스냅샷을 가져오는 데 사용할 연결 풀입니다 |
Fetch Size |
한 번에 메모리에 로딩되는 최대 행 수입니다 |
JDBC Driver Location |
쉼표로 구분된 파일/폴더 목록 및/또는 URLs 드라이버 JAR 및 종속성(있는 경우)이 포함된 목록입니다. 예: ‘/var/tmp/postgresql-java-client-42.7.5.jar’ |
Max Batch Size |
단일 배치에서 가져올 최대 행 수입니다 |
Record Writer |
가져온 스냅샷을 작성하는 데 사용할 Record Writer |
Schema Name |
스냅샷을 가져올 스키마의 이름입니다 |
테이블 이름 |
스냅샷을 가져올 테이블의 이름입니다 |
관계¶
이름 |
설명 |
---|---|
complete |
스냅샷이 완료되면 원본 FlowFile 은 이 관계로 라우팅됩니다 |
실패 |
FlowFile 로 표시된 테이블에서 데이터를 검색할 수 없는 경우 FlowFile 은 이 관계로 라우팅됩니다. |
retryable failure |
FlowFile 로 표시된 테이블에서 데이터를 검색할 수 없지만 향후 가능할 것으로 예상되는 경우 FlowFile 은 관계로 라우팅됩니다. |
rows |
FlowFile 로 표시되는 테이블에서 스냅샷이 성공적으로 검색되면 행이 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
---|---|
snapshot.complete |
스냅샷이 완료되었는지 여부를 나타냅니다 |
rows.total.fetched |
테이블에 대해 가져온 총 행 수입니다 |
rows.delta.fetched |
마지막 반복에서 테이블에 대해 가져온 행 수입니다 |
start.row.index |
지정된 반복에 대한 스냅샷 내 첫 번째 행의 인덱스(0부터 시작)입니다 |
last.row.index |
지정된 반복에 대한 스냅샷 내 마지막 행의 인덱스(0부터 시작)입니다 |
fetch.delta.time.in.millis |
마지막 반복에서 행을 가져오는 데 걸린 시간(밀리초)입니다 |
fetch.total.time.in.millis |
행을 가져오는 데 지금까지 걸린 시간(밀리초)입니다 |