EnrichCdcStream 2025.5.31.15¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
CaptureChangePostgreSQL 등으로부터 수신 FlowFiles 에 어느 저널 테이블에 쓸지 관련 정보와 관련 스키마 정보를 보강합니다. 이 프로세서는 처리 중인 각 테이블의 스키마 버전을 관리하여 각 FlowFile 에 대해 올바른 저널 테이블이 사용되는지 확인합니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
CDC Schema Registry |
CDC 데이터의 스키마를 관리하는 데 사용할 CDC Schema Registry를 지정합니다 |
Record Reader |
수신 데이터를 읽는 데 사용할 Record Reader를 지정합니다 |
Record Writer |
발신 데이터 쓰기에 사용할 Record Writer를 지정합니다 |
Table State Service |
복제된 테이블의 상태를 보유합니다 |
상태 관리¶
범위 |
설명 |
|---|---|
CLUSTER |
처리 중인 각 테이블의 현재 저널 테이블 버전을 추적합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFile 을 읽을 수 없는 경우 이 관계로 라우팅됩니다. |
schema update |
수신 레코드를 처리하기 위해 스키마 업데이트가 필요한 경우 FlowFile 은 이 관계로 라우팅됩니다. FlowFile 에는 변경이 필수임을 나타내는 스키마 정보가 포함됩니다. |
skipped ddl event |
이 관계는 대상 테이블의 스키마 변경을 초래하지 않는 DDL / 스키마 변경 이벤트에 사용됩니다. |
성공 |
Snowflake 테이블에 삽입할 행은 이 관계로 라우팅됩니다. |
table not in state |
FlowFile 이 복제된 테이블의 상태에 존재하지 않는 테이블을 참조할 때(아마도 복제에서 제거된 후) 사용됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
table.schema.generation |
증분 처리를 위한 저널 테이블의 인덱스입니다. |
table.schema.initial |
저널 테이블의 초기 생성을 표시합니다. |
destination.table.schema |
대상 테이블에 대한 업데이트된 스키마입니다. 이 특성은 DDL 이벤트에만 작성됩니다. |