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이에요.

더 알아보기 (Learn more)