UpdateSnowflakeTable 2025.10.2.19

번들

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

설명

수신 FlowFile에 제공된 스키마를 기준으로 Snowflake 테이블의 정의를 업데이트합니다. 스키마는 FlowFile 내용을 통해 제공되는지 또는 속성으로 지정되는지에 관계없이 다음 형식으로 JSON에 있을 것으로 예상됩니다. { “columns”: [ { “name”: “<column name>”, “type”: “<column type>”, “nullable”: <true/false>, “precision”: <only for numeric type>, “scale”: <only for numeric type> }, … ], “primaryKeys”: [“<name of first primary key column>”, “<name of second primary key column>”, …] } 이 프로세서는 테이블 생성, 변경, 삭제 등 테이블 전용 작업을 지원합니다.

태그

alter, columns, create, ddl, drop, preview, snowflake, table, update

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

Add Column Strategy

수신 스키마에 기존 테이블에 없는 열이 있는 경우 사용할 전략

Add Not Null Strategy

수신 스키마에 기존 테이블에 없는 null이 아닌 제약 조건이 있을 때 사용하는 전략입니다

열 유형 전략 변경

기존 테이블에 수신 스키마와 유형이 다른 열이 있는 경우 사용할 전략입니다.

열 이름 변환

스키마에 정의된 열의 이름에 적용할 수 있는 선택적 변환입니다. 이 변환은 테이블의 기존 열과 비교되기 전에 열 이름에 적용됩니다. 이 속성은 특성 외에도 표현식 언어를 통해 다음 변수를 참조할 수 있습니다. column.name, column.type, column.nullable, column.precision, column.scale, column.primaryKey. 이 속성을 기준으로 변환을 적용한 결과는 오브젝트 이름 처리 속성의 설정에 따라 처리됩니다.

Column Removal Strategy

기존 테이블에 수신 스키마에 없는 열이 있는 경우 사용할 전략

Connection Pool

Snowflake에 연결하는 데 사용할 연결 풀입니다

생성 매개 변수

CREATE TABLE 문에 포함할 추가 매개 변수. 예: ‘CLUSTER BY (column_name)’

필요한 스키마

필요한 스키마/테이블 정의

Drop Column Strategy

기존 테이블에 수신 스키마에 없는 열이 있는 경우 사용할 전략

Drop Not Null Strategy

기존 테이블에 수신 스키마에 없는 null이 아닌 제약 조건이 있을 때 사용하는 전략

기본값 포함

CREATE TABLE 또는 ALTER TABLE ADD COLUMN 문에 DEFAULT 값을 포함할지 여부

Include not null 제약 조건

CREATE TABLE 또는 ALTER TABLE ADD COLUMN 문에 NOT NULL 제약 조건을 포함할지 여부

기본 키 제약 조건 포함하기

생성 문에 기본 키 제약 조건을 포함할지 여부

Max Batch Size

지정된 테이블에 대해 한 번의 실행으로 처리할 수 있는 최대 FlowFiles 개수입니다.

Modify Primary Key Strategy

수신 스키마에 기존 기본 키와 다른 기본 키가 있을 때 사용하는 전략입니다. 기본 키를 수정하려면 기존 키가 있는 경우 삭제하고 새 키를 추가해야 합니다.

오브젝트 식별자 확인

Snowflake에서 소스 오브젝트 식별자(스키마, 테이블, 열)를 저장하고 쿼리하는 방법을 제어합니다. 이 설정은 SQL 쿼리에서 큰따옴표를 사용해야 하는지 여부를 결정합니다.

Record Reader

원하는 스키마를 얻기 위해 사용할 Record Reader

열 이름 접미사 제거

제거된 열에 추가할 접미사입니다. 예를 들어, ‘foo’ 열의 이름을 ‘foo__deleted’로 바꾸려면 속성을 __deleted`로 설정할 있습니다. 속성 값은 `오브젝트 이름 처리 속성의 값에 따라 다르게 동작합니다. 즉 `오브젝트 이름 처리`가 `대소문자 구분 이름`으로 설정된 경우 접미사가 그대로 추가됩니다. `오브젝트 이름 처리`가 `SQL 식별자`로 설정된 경우 접미사는 문자, 숫자, 달러 기호($), 밑줄(_) 문자로만 구성되어야 하며, 추가되는 열 이름이 대소문자를 구분하지 않는 경우(따옴표로 묶지 않은 경우) 대소문자 구분 없이 추가되고, 반대로 대소문자를 구분하는 경우(따옴표로 묶은 경우) 대소문자를 구분하여 추가됩니다.

Schema Name

테이블이 포함된 스키마의 이름입니다.

테이블 메타데이터 캐시 만료 시간

캐시 항목이 제거될 시간(초)입니다

테이블 이름

업데이트할 테이블의 이름입니다

Table Schema Strategy

원하는 스키마/테이블 정의를 얻는 방법을 지정합니다

업데이트 유형

수행할 테이블 업데이트의 유형

테이블 메타데이터 캐시 사용

테이블 메타데이터를 Snowflake에서 직접 읽는 대신 캐시할지 여부입니다. [Create Table If Not Exists, Alter Table]에 적용됩니다

관계

이름

설명

실패

테이블을 업데이트할 수 없는 경우 수신 FlowFile 은 이 관계로 라우팅됩니다

성공

수신 FlowFile 은 테이블이 성공적으로 업데이트된 후 이 관계로 라우팅됩니다

Writes 특성

이름

설명

schema.hash

모든 업데이트가 완료된 후 최종 테이블 스키마의 SHA-256 해시입니다. 변경 감지 및 캐싱 목적으로 사용할 수 있습니다.