UpdateSnowflakeDatabase 2025.5.31.15

번들

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

설명

수신 FlowFile 에 제공된 스키마를 기반으로 Snowflake 테이블의 정의를 업데이트합니다. 스키마는 FlowFile 내용을 통해 제공되거나 { “columns”: [ { “name”: “<column name>”, “type”: “<column type>”, “nullable”: <true/false>, “precision”: <precision, only for numeric type>, “scale”: <scale, only for numeric type> }, … ], “primaryKeys”: [“<name of first primary key column>”, “<name of second primary key column>”, …]} 속성으로 지정되었는지 여부에 관계없이 다음 형식의 JSON 으로 예상됩니다.

태그

입력 요구 사항

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에 연결하는 데 사용할 연결 풀입니다

스트림 생성하기

테이블에 대한 Snowflake 스트림을 생성할지 여부

생성 매개 변수

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

필요한 스키마

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

Drop Column Strategy

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

Drop Not Null Strategy

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

Include not null 제약 조건

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

기본 키 제약 조건 포함하기

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

Max Batch Size

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

Modify Primary Key Strategy

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

Record Reader

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

열 이름 접미사 제거

제거된 열에 추가할 접미사, 예를 들어, ‘foo’ 열의 이름을 ‘foo__deleted’로 변경하려면 속성을 __deleted 로 설정할 수 있습니다

Schema Name

업데이트할 스키마의 이름입니다

스트림 생성 매개 변수

CREATE STREAM 문에 포함할 추가 매개 변수. 예: ‘APPEND_ONLY=TRUE’

스트림 이름

스트림의 이름

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

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

테이블 이름

스트림을 업데이트하거나 생성할 테이블의 이름입니다

Table Schema Strategy

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

테이블 스트림 생성 매개 변수

CREATE STREAM 문에 포함할 매개 변수입니다. 예: ‘APPEND_ONLY=TRUE’. 스트림은 소스인 테이블과 함께 생성됩니다.

테이블 스트림 이름

테이블과 함께 생성된 스트림의 이름입니다. 스트림 소스는 생성된 테이블이 됩니다.

업데이트 유형

수행할 업데이트 유형

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

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

관계

이름

설명

실패

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

성공

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