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 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’로 변경하려면 속성을 |
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 은 테이블이 성공적으로 업데이트된 후 이 관계로 라우팅됩니다 |