ListTableNames
ListTableNames
모든 소스 테이블 이름을 가져와 가능한 구성 중 하나와 매칭하는 프로세서예요. - regexp 표현(예: “(?i)customer.(orders|payments)”)은 대소문자를 구분하지 않는 방식으로 이름을 매칭해요. “CUSTOMER.ORDERS”와 “customer.orders” 소스 테이블 이름 모두와 일치해요. - 소스 테이블 이름의 쉼표로 구분된 목록(예: “customer.orders, customer.payments”)은 소스 테이블 이름을 대소문자 구분 방식으로 매칭해요. 즉 “customer.orders” 소스 테이블은 MATCH 관계로 전달되지만 “customer.ORDERS”는 일치하지 않아요. 복제할 수 없는 매칭된 소스 테이블은 각 테이블이 별도의 FlowFile로, 속성에 이유(reason)와 함께 FAILURE 관계로 연결돼요. 구성은 FlowFile 특성으로 전달돼요. 소스 테이블 이름은 <schema_name>.<table_name>으로 표현되므로 두 입력 모두 이를 고려해야 해요. 매칭된 소스 테이블 이름은 MATCHED 관계로 전달돼요. 프로세서는 매칭된 테이블로 단일 FlowFile을 생성해요. 주의 사항 - Postgresql은 데이터베이스 객체 이름을 대소문자 구분 또는 대소문자 무시 방식으로 정의할 수 있게 해요. 사용자가 'CREATE TABLE ORDERS(id int not null)' 같은 쿼리로 테이블을 만들면 내부적으로 Postgresql은 orders처럼 소문자로 저장해요. 대소문자 구분을 적용하려면 사용자는 테이블 이름을 큰따옴표로 감싸야 해요. 예: 'CREATE TABLE "ORDERS"(id int not null)'. 복제하려는 테이블을 구성할 때 이 점이 중요한 측면이에요.
출처: Snowflake 문서
본문
기능 — 일반 제공(Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.
Bundle
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명 (Description)
모든 소스 테이블 이름을 가져와 가능한 구성 중 하나와 매칭해요. - regexp 표현(예: “(?i)customer.(orders|payments)”)은 대소문자를 구분하지 않는 방식으로 이름을 매칭해요. “CUSTOMER.ORDERS”와 “customer.orders” 소스 테이블 이름 모두와 일치해요. - 소스 테이블 이름의 쉼표로 구분된 목록(예: “customer.orders, customer.payments”)은 대소문자 구분 방식으로 소스 테이블 이름을 매칭해요. 즉 “customer.orders” 소스 테이블은 MATCH 관계로 전달되지만 “customer.ORDERS”는 일치하지 않아요. 복제할 수 없는 매칭된 소스 테이블은 각 테이블이 별도의 FlowFile로, 속성에 이유(reason)를 담아 FAILURE 관계로 연결돼요. 구성은 FlowFile 특성으로 전달돼요. 소스 테이블 이름은 <schema_name>.<table_name>으로 표현되므로 두 입력 모두 이를 고려해야 해요. 매칭된 소스 테이블 이름은 MATCHED 관계로 전달돼요. 프로세서는 매칭된 테이블로 단일 FlowFile을 생성해요. 주의 사항 - Postgresql은 데이터베이스 객체 이름을 대소문자 구분 또는 대소문자 무시 방식으로 정의할 수 있게 해요. 사용자가 'CREATE TABLE ORDERS(id int not null)' 같은 쿼리로 테이블을 만들면 내부적으로 Postgresql은 소문자(orders)로 저장해요. 대소문자 구분을 적용하려면 사용자가 테이블 이름을 큰따옴표로 감싸야 해요. 즉 'CREATE TABLE "ORDERS"(id int not null)'. 복제하려는 테이블을 구성할 때 이 점이 중요한 측면이에요.
태그 (Tags)
없음
입력 요구사항 (Input Requirement)
REQUIRED (필수)
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| Property | Description |
|---|---|
| Connection Pool | 데이터베이스에 대한 연결을 얻는 데 사용하는 Controller Service예요. |
| Included Comma Separated Source Table Names | 복제할 테이블의 쉼표로 구분된 목록이에요. 단일 테이블은 <schema_name>.<table_name> 형식이어야 해요. 예: customer.orders, customer.payments. 일치하는 테이블을 포함하도록 정규식과 결합돼요. |
| Included Source Table Pattern | 복제할 테이블 이름을 지정하는 Regular Expression이에요. 예: customer.(orders |
관계 (Relationships)
| Name | Description |
|---|---|
| failure | FlowFile 속성을 읽을 수 없거나 올바르지 않으면 이 Relationship으로 연결돼요. |
| matched | 소스 데이터베이스에서 찾은 일치하는 테이블 목록이 포함된 FlowFile을 성공적으로 생성했어요. |
쓰기 속성 (Writes attributes)
| Name | Description |
|---|---|
| source.schema.name | 이벤트가 발생한 테이블의 스키마 이름이에요. |
| source.table.name | 이벤트가 발생한 테이블의 이름이에요. |
| source.entry | 테이블 이름을 처리할 때 파싱하려고 시도한 원래 항목이에요. |
| reason | 테이블을 복제할 수 없는 이유예요. |
| source.database.version.major | 소스 데이터베이스의 major 버전이에요. |
| mime.type | FlowFile 콘텐츠의 MIME type이에요. |