Iceberg 테이블 관리하기¶

이 항목에서는 Iceberg 테이블 을 관리하는 데 도움이 되는 다음 작업을 다룹니다.

테이블 메타데이터를 수동으로 새로 고치기
DML 변경 사항의 스냅샷 생성하기
Iceberg 테이블 쿼리하기
Iceberg 테이블 업데이트하기
Iceberg 테이블에 대한 저장소 메트릭 검색하기

또한 카탈로그 통합을 사용하는 Iceberg 테이블을 Snowflake를 Iceberg 카탈로그로 사용하는 테이블로 변환할 수도 있습니다. 자세한 내용은 Iceberg 테이블 변환하기 을 참조하십시오.

테이블 메타데이터를 수동으로 새로 고치기¶

카탈로그 통합을 사용할 때 ALTER ICEBERG TABLE 명령을 사용하여 지정된 Iceberg 메타데이터 파일에서 테이블 메타데이터를 새로 고칠 수 있습니다. 테이블 메타데이터를 새로 고치면 메타데이터가 가장 최근 테이블 변경 사항과 동기화됩니다.

AWS Glue를 카탈로그로 사용하는 Iceberg 테이블의 메타데이터 새로 고치기¶

다음 예에서는 Iceberg 카탈로그에 AWS Glue를 사용하는 테이블의 메타데이터를 수동으로 새로 고칩니다. 테이블을 새로 고치면 테이블이 AWS Glue에서 발생한 모든 변경 사항과 동기화된 상태로 유지됩니다.

이러한 유형의 Iceberg 테이블을 사용할 경우 명령에 메타데이터 파일 경로를 지정하지 않습니다.

ALTER ICEBERG TABLE my_iceberg_table REFRESH;

Copy

오브젝트 저장소의 파일에서 생성된 Iceberg 테이블의 메타데이터 새로 고치기¶

다음 예에서는 메타데이터 파일의 상대 경로를 지정하여 외부 클라우드 저장소 위치에 있는 Iceberg 메타데이터 파일에서 생성된 테이블을 수동으로 새로 고칩니다. 메타데이터 파일은 새로 고친 후 테이블의 데이터를 정의합니다.

ALTER ICEBERG TABLE my_iceberg_table REFRESH 'metadata/v1.metadata.json';

Copy

DML 변경 사항의 스냅샷 생성하기¶

Snowflake를 카탈로그로 사용하는 테이블의 경우 Snowflake는 Iceberg 메타데이터를 자동으로 생성합니다. Snowflake는 테이블이 생성될 때 BASE_LOCATION 매개 변수로 지정된 위치에 있는 외부 볼륨의 metadata 라는 폴더에 메타데이터를 기록합니다.

또는 SYSTEM$GET_ICEBERG_TABLE_INFORMATION 함수를 호출하여 새로운 변경 사항에 대한 Iceberg 메타데이터를 생성할 수 있습니다.

예:

SELECT SYSTEM$GET_ICEBERG_TABLE_INFORMATION('db1.schema1.it1');

Copy

출력:

+-----------------------------------------------------------------------------------------------------------+
| SYSTEM$GET_ICEBERG_TABLE_INFORMATION('DB1.SCHEMA1.IT1')                                                   |
|-----------------------------------------------------------------------------------------------------------|
| {"metadataLocation":"s3://mybucket/metadata/v1.metadata.json","status":"success"}                         |
+-----------------------------------------------------------------------------------------------------------+

Iceberg 테이블 쿼리하기¶

Iceberg 테이블을 쿼리하려면 사용자에게 다음 권한을 부여하거나 상속해야 합니다.

테이블이 포함된 데이터베이스 및 스키마에 대한 USAGE 권한.
테이블에 대한 SELECT 권한.

SELECT 문을 사용하여 Iceberg 테이블을 쿼리할 수 있습니다. 예:

SELECT col1, col2 FROM my_iceberg_table;

Copy

Iceberg 테이블 업데이트하기¶

INSERT 및 UPDATE 문을 사용하여 Snowflake를 카탈로그로 사용하는 Iceberg 테이블을 수정할 수 있습니다.

다음 예제에서는 store_sales 라는 Iceberg 테이블에 새 값을 삽입한 다음, 값이 현재 -99인 경우 cola 열을 1로 업데이트합니다.

INSERT INTO store_sales values (-99);

UPDATE store_sales
  SET cola = 1
  WHERE cola = -99;

Copy

Iceberg 테이블에 대한 저장소 메트릭 검색하기¶

Snowflake는 Iceberg 테이블 저장소 비용을 귀하의 계정에 청구하지 않습니다. 그러나 Snowflake Information Schema 또는 Account Usage 스키마에서 TABLE_STORAGE_METRICS 및 TABLES 뷰를 쿼리하여 Iceberg 테이블이 차지하는 저장 용량을 추적할 수 있습니다.

다음 예제 쿼리는 ACCOUNT_USAGE.TABLE_STORAGE_METRICS 뷰를 ACCOUNT_USAGE.TABLES 뷰와 조인하여 TABLES.IS_ICEBERG 열을 필터링합니다.

SELECT metrics.* FROM
  snowflake.account_usage.table_storage_metrics metrics
  INNER JOIN snowflake.account_usage.tables tables
  ON (
    metrics.id = tables.table_id
    AND metrics.table_schema_id = tables.table_schema_id
    AND metrics.table_catalog_id = tables.table_catalog_id
  )
  WHERE tables.is_iceberg='YES';

Copy