여러 계정에서 데이터베이스 복제하기¶

기본 데이터베이스 관리하기¶

1. 기본 데이터베이스가 포함된 Snowflake 계정으로 Snowsight 에 로그인합니다.

2. 왼쪽 상단(로그인 이름 옆) » Switch Role » ACCOUNTADMIN 에서 드롭다운 메뉴를 선택합니다.

3. 왼쪽 탐색 창에서 Data » Databases 를 선택합니다. 데이터베이스 오브젝트 탐색기에서 기본 데이터베이스를 선택합니다. 데이터베이스 세부 정보 페이지가 열립니다.

   또는 복제를 위해 활성화된 데이터베이스만 보려면 Replication Status » Primary 필터를 사용하여 계정의 기본 데이터베이스를 나열하십시오. 목록에서 데이터베이스를 선택하여 세부 정보 페이지를 엽니다.

   참고

   Replication Status 필터는 계정이 데이터베이스 복제의 원본 또는 대상 계정인 경우에만 사용할 수 있습니다.

4. » Enable Replication 를 선택합니다. Enable replication 대화 상자가 열립니다.

   수행하려는 작업을 선택합니다.

   • 장애 조치를 활성화합니다. 이 기능을 사용하려면 Business Critical Edition 이상이 필요합니다.

   • 하나 이상의 대상 계정에 보조 데이터베이스를 만듭니다.

     다른 계정의 기본 데이터베이스가 현재 계정으로 복제되도록 활성화된 경우 현재 계정에 보조 데이터베이스를 생성할 수 있습니다. 대상 계정을 더 추가하려면 원본 계정에서 ALTER DATABASE 명령을 사용하여 기본 데이터베이스를 업데이트합니다.

   • 생성된 각 보조 데이터베이스를 한 번 새로 고칩니다.

5. 이 데이터베이스의 각 대상 계정에 대해 보조 데이터베이스를 생성하고 데이터베이스를 새로 고치는 옵션을 선택합니다.

6. 이전에 해당 계정에서 ACCOUNTADMIN 역할의 사용자로 대상 계정에 로그인합니다.

   Snowflake가 요청된 작업을 수행하고 성공 대화 상자를 표시합니다.

   데이터베이스 세부 정보의 Replication 탭에서 이 데이터베이스에 대한 복제를 관리합니다.

보조 데이터베이스 관리하기¶

1. 보조 데이터베이스가 포함된 Snowflake 계정으로 Snowsight 에 로그인합니다.

2. 왼쪽 상단(로그인 이름 옆) » Switch Role » ACCOUNTADMIN 에서 드롭다운 메뉴를 선택합니다.

3. 왼쪽 탐색 창에서 Data » Databases 를 선택합니다.

   페이지의 오른쪽 상단 모서리에 있는 작업(…) 버튼에서 다음 작업을 수행할 수 있습니다.

   • 보조 데이터베이스를 만듭니다.

     참고

     이 옵션은 계정이 데이터베이스 복제의 원본 또는 대상 계정인 경우에만 사용할 수 있습니다.

     다른 계정의 기본 데이터베이스가 현재 계정으로 복제되도록 활성화된 경우 현재 계정에 보조 데이터베이스를 생성할 수 있습니다. 대상 계정을 더 추가하려면 원본 계정에서 ALTER DATABASE 명령을 사용하여 기본 데이터베이스를 업데이트합니다.

4. 데이터베이스 오브젝트 탐색기에서 보조 데이터베이스를 선택합니다. 데이터베이스 세부 정보 페이지가 열립니다.

5. Replication 탭을 선택합니다.

   페이지의 오른쪽 상단 모서리에 있는 작업(…) 버튼에서 다음 작업을 수행할 수 있습니다.

   • 기본 데이터베이스로 사용할 보조 데이터베이스를 승격합니다. 이 기능을 사용하려면 Business Critical Edition 이상이 필요합니다.

     참고

     기본 데이터베이스 역할을 하도록 보조 데이터베이스를 승격하려면 기본 데이터베이스에서 보조 데이터베이스가 있는 대상 계정에 대해 장애 조치를 활성화해야 합니다.

     이 옵션을 사용할 수 없는 경우 원본 계정에서 ALTER DATABASE 명령을 사용하여 기본 데이터베이스에 대한 장애 조치를 대상 계정으로 활성화할 수 있습니다. 자세한 내용은 3단계: 기본 데이터베이스에 대한 장애 조치 활성화 섹션을 참조하십시오.

   • 보조 데이터베이스를 새로 고칩니다.

   • 템플릿을 복사하여 일정에 따라 보조 데이터베이스를 새로 고치는 작업을 생성합니다. 템플릿을 Snowsight 워크시트에 붙여넣고 편집하여 원하는 일정을 지정합니다.

1단계: 조직의 모든 계정 보기¶

조직에서 복제가 활성화된 계정의 목록을 검색합니다. 이러한 계정의 기존 영구 또는 임시 데이터베이스는 기본 데이터베이스로 사용하도록 수정할 수 있습니다. 기본 데이터베이스(즉, 보조 데이터베이스)의 복제본은 이러한 계정에서만 생성할 수 있습니다.

조직의 계정 목록을 살펴보려면 SHOW REPLICATION ACCOUNTS 를 쿼리합니다.

SHOW REPLICATION ACCOUNTS;

+------------------+---------------------------------+---------------+------------------+---------+-------------------+
| snowflake_region | created_on                      | account_name  | account_locator  | comment | organization_name |
|------------------+---------------------------------+---------------+------------------+---------+-------------------|
| AWS_US_WEST_2    | 2018-11-19 16:11:12.720 -0700   | ACCOUNT1      | MYACCOUNT1       |         | MYORG             |
| AWS_US_EAST_1    | 2019-06-02 14:12:23.192 -0700   | ACCOUNT2      | MYACCOUNT2       |         | MYORG             |
+------------------+---------------------------------+---------------+------------------+---------+-------------------+

리전 IDs 전체 목록을 살펴봅니다.

2단계: 로컬 데이터베이스를 기본 데이터베이스로 승격¶

ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS 문을 사용하여 기본 데이터베이스 역할을 하도록 기존 영구 또는 임시 데이터베이스 수정합니다. 조직에서 이 데이터베이스(즉, 보조 데이터베이스)의 복제본을 저장할 수 있는 쉼표로 구분된 계정 목록을 제공하여 해당 계정의 사용자가 보조 데이터베이스의 오브젝트를 쿼리할 수 있도록 합니다.

ALTER DATABASE mydb1 ENABLE REPLICATION TO ACCOUNTS myorg.account2, myorg.account3;

3단계: 기본 데이터베이스에 대한 장애 조치 활성화¶

ALTER DATABASE … ENABLE FAILOVER TO ACCOUNTS 문을 사용하여 조직의 하나 이상의 계정에 대한 기본 데이터베이스의 장애 조치를 활성화합니다. 이러한 계정(즉, 보조 데이터베이스) 중 하나에 있는 이 기본 데이터베이스의 복제본을 승격하여 기본 데이터베이스로 사용할 수 있습니다.

기본 데이터베이스에 대한 장애 조치 활성화는 또는 지정된 계정에서 기본 데이터베이스의 복제본이 생성된 후에 수행할 수 있습니다.

-- Executed from primary account
ALTER DATABASE mydb1 ENABLE FAILOVER TO ACCOUNTS myorg.account2, myorg.account3;

4단계: 보조 데이터베이스 만들기¶

기본 데이터베이스를 저장하는 동일한 계정 또는 다른 계정(동일하거나 다른 리전)에 기존 기본 데이터베이스의 복제본을 생성합니다. 보조 데이터베이스는 2단계: 로컬 데이터베이스를 기본 데이터베이스로 승격 의 ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS 문에 지정된 계정에서만 생성할 수 있음에 유의하십시오.

각 대상 계정에서 CREATE DATABASE … AS REPLICA OF 문을 실행하여 지정된 기본 데이터베이스의 복제본을 생성합니다.

조직의 기본 및 보조 데이터베이스 목록을 보려면 SHOW REPLICATION DATABASES 를 쿼리합니다. 보조 데이터베이스가 생성된 후 계정 관리자는 데이터베이스의 소유권을 다른 역할로 이전할 수 있습니다(GRANT OWNERSHIP 사용).

-- Log into the ACCOUNT2 account.

-- Query the set of primary and secondary databases in your organization.
-- In this example, the MYORG.ACCOUNT1 primary database is available to replicate.
SHOW REPLICATION DATABASES;

+------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------+
| snowflake_region | created_on                    | account_name    | name     | comment | is_primary | primary                    | replication_allowed_to_accounts | failover_allowed_to_accounts | organization_name | account_locator |
|------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------|
| AWS_US_WEST_2    | 2019-11-15 00:51:45.473 -0700 | ACCOUNT1        | MYDB1    | NULL    | true       | MYORG.ACCOUNT1.MYDB1       | MYORG.ACCOUNT2, MYORG,ACCOUNT1  | MYORG.ACCOUNT1               | MYORG             | MYACCOUNT1      |
+------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------+

-- Create a replica of the 'mydb1' primary database
-- If the primary database has the DATA_RETENTION_TIME_IN_DAYS parameter set to a value other than the default value,
-- set the same value for the parameter on the secondary database.
CREATE DATABASE mydb1
  AS REPLICA OF myorg.account1.mydb1
  DATA_RETENTION_TIME_IN_DAYS = 10;

-- Verify the secondary database
SHOW REPLICATION DATABASES;

+------------------+-------------------------------+---------------+----------+---------+------------+-------------------------+---------------------------------+------------------------------+-------------------+-----------------+
| snowflake_region | created_on                    | account_name  | name     | comment | is_primary | primary                 | replication_allowed_to_accounts | failover_allowed_to_accounts | organization_name | account_locator |
|------------------+-------------------------------+---------------+----------+---------+------------+------------------------------------------+----------------+------------------------------+-------------------------------------|
| AWS_US_WEST_2    | 2019-11-15 00:51:45.473 -0700 | ACCOUNT1      | MYDB1    | NULL    | true       | MYORG.ACCOUNT1.MYDB1    | MYORG.ACCOUNT2, MYORG.ACCOUNT1  | MYORG.ACCOUNT1               | MYORG             | MYACCOUNT1      |
| AWS_US_EAST_1    | 2019-08-15 15:51:49.094 -0700 | ACCOUNT2      | MYDB1    | NULL    | false      | MYORG.ACCOUNT1.MYDB1    |                                 |                              | MYORG             | MYACCOUNT2      |
+------------------+-------------------------------+---------------+----------+---------+------------+-------------------------+---------------------------------+------------------------------+-------------------+-----------------+

5단계. 각 보조 데이터베이스 새로 고침¶

이 섹션의 지침은 기본 데이터베이스의 스냅샷에서 보조 데이터베이스를 새로 고치는 방법(ALTER DATABASE … REFRESH 사용)을 설명합니다. 스냅샷에는 오브젝트 및 데이터 변경 사항이 포함됩니다. 매우 큰 기본 데이터베이스의 초기 복제의 경우 문의 시간 제한 을 늘리는 것이 좋습니다.

계정에 로그인한 후 현재 리전을 확인하려면 CURRENT_REGION 함수를 쿼리합니다.

ALTER DATABASE mydb1 REFRESH;

웹 UI에서 보조 데이터베이스 새로 고침 을 수행할 수도 있습니다.

6단계. 일정에 따라 보조 데이터베이스 새로 고침¶

모범 사례로, 보조 데이터베이스 새로 고침을 예약하는 것이 좋습니다. 이 섹션에서는 지정된 일정에 따라 데이터베이스 새로 고침을 자동으로 시작하는 지침을 제공합니다.

보조 데이터베이스를 새로 고치는 빈도는 보조 데이터베이스의 데이터에 대한 복구 시점 목표(RPO)에 따라 다릅니다. 예를 들어, 데이터에 의존하는 애플리케이션이 최대 1시간의 데이터 손실을 허용할 수 있는 경우 최소한으로 매시간마다 데이터를 새로 고쳐야 합니다. 데이터 손실 허용 범위가 5분이면 최소한 5분마다 보조 데이터베이스를 새로 고칩니다.

지정된 일정에 따라 데이터베이스 새로 고침을 자동으로 시작하려면 이 섹션의 단계를 완료하십시오.

전제 조건:

보조 데이터베이스를 저장하는 계정에 필요한 Snowflake 오브젝트는 다음과 같습니다.

• 보조 데이터베이스.

• 이 섹션에서 생성되는 새 오브젝트를 저장하기 위한 별도의 데이터베이스입니다. 보조 데이터베이스는 읽기 전용이므로, 이 데이터베이스는 보조 데이터베이스와 분리되어야 합니다. 이 데이터베이스에 포함되어야 하는 오브젝트는 다음과 같습니다.

  • 스키마. PUBLIC 스키마를 사용하거나 CREATE SCHEMA 를 사용하여 새 스키마를 생성합니다.

  • 웨어하우스. 구문 요구 사항을 충족하기 위해 모든 웨어하우스를 여기에 제공할 수 있지만 데이터베이스 새로 고침에는 사용되지 않습니다. CREATE WAREHOUSE 를 사용하여 새 웨어하우스를 생성합니다.

  • 일정에 따라 보조 데이터베이스를 새로 고치는 작업입니다.

필수 권한:

이 섹션의 단계에는 보조 데이터베이스를 새로 고치는 계정에서 다음 권한이 있는 역할이 필요합니다.

오브젝트 타입	오브젝트	권한	참고
계정	보조 데이터베이스를 저장하는 계정	EXECUTE TASK	새 작업을 실행하기 위해 필요합니다.
데이터베이스	보조 데이터베이스	OWNERSHIP	보조 데이터베이스를 새로 고치기 위해 필요합니다.
데이터베이스	새 작업을 저장하는 데이터베이스	USAGE
스키마	새 작업을 저장하는 스키마	USAGE, CREATE TASK
작업		OWNERSHIP	작업을 생성하는 역할은 기본적으로 오브젝트를 소유합니다. 소유권은 GRANT privileges … TO ROLE 을 사용하여 다른 역할로 이전할 수 있습니다.
웨어하우스	작업을 구성하기 위해 사용되는 웨어하우스	USAGE	작업을 구성하려면 웨어하우스를 지정해야 하지만, 웨어하우스는 작업을 실행하거나 새로 고침 작업을 수행하는 데 사용되지 않습니다.

단계:

일정에 따라 새로 고칠 각 보조 데이터베이스에 대해 다음 단계를 완료합니다.

1. 일정에 따라 데이터베이스 새로 고침을 시작하는 태스크를 생성(CREATE TASK 사용)합니다. 복제 일정을 지정하기 위한 CREATE TASK 구문에는 웨어하우스가 필요하지만 웨어하우스는 복제에 사용되지 않습니다.

   예를 들어, 4시간의 시간 제한으로 10분마다 이름이 mydb1 인 보조 데이터베이스를 새로 고치는 이름이 refresh_mydb1_task 인 태스크를 생성합니다. 태스크는 기존 웨어하우스인 mywh 를 사용하여 구성됩니다.

   CREATE TASK refresh_mydb1_task
     WAREHOUSE = mywh
     SCHEDULE = '10 minute'
     USER_TASK_TIMEOUT_MS = 14400000
   AS
     ALTER DATABASE mydb1 REFRESH;
   

   Copy

2. 태스크는 생성될 때 기본적으로 일시 중단됩니다. 태스크 정의에 지정된 매개 변수를 기반으로 실행할 수 있도록 태스크를 재개합니다.

ALTER TASK refresh_mydb1_task RESUME;

Copy

예¶

원하는 Snowflake 클라이언트에서 다음 SQL 문을 실행하여 복제 및 장애 조치를 활성화하고 초기 데이터베이스 새로 고침을 수행하고 예약된 새로 고침을 설정합니다.

-- The commands below are executed from the source account

-- View replication enabled accounts
SHOW REPLICATION ACCOUNTS;

ALTER DATABASE mydb ENABLE REPLICATION TO ACCOUNTS myorg.account2, myorg.account3;
ALTER DATABASE mydb ENABLE FAILOVER TO ACCOUNTS myorg.account2, myorg.account3;

-- The commands below are executed from each target account

-- View replication enabled databases
-- Note the primary column of the source database for the CREATE DATABASE statement below
SHOW REPLICATION DATABASES;

-- If the primary database has the DATA_RETENTION_TIME_IN_DAYS parameter set to a value other than the default value,
-- set the same value for the parameter on the secondary database.
CREATE DATABASE mydb
  AS REPLICA OF myorg.account1.mydb
  DATA_RETENTION_TIME_IN_DAYS = 10;

-- Increase statement timeout for initial refresh
-- Optional but recommended for initial refresh of a large database
ALTER SESSION SET STATEMENT_TIMEOUT_IN_SECONDS = 604800;
-- If you have an active warehouse in current session, update warehouse statement timeout
SELECT CURRENT_WAREHOUSE();
ALTER WAREHOUSE my_wh SET STATEMENT_TIMEOUT_IN_SECONDS = 604800;
-- Reset warehouse statement timeout after initial refresh
ALTER WAREHOUSE my_wh UNSET STATEMENT_TIMEOUT_IN_SECONDS;

-- Refresh a secondary database
ALTER DATABASE mydb REFRESH;

-- Create task
-- Set up refresh schedule for each secondary database using a separate database
USE DATABASE my_db2;

-- Create a task and RESUME the task for each secondary database
-- Edit the task schedule and timeout for your specific use case
CREATE TASK my_refresh_task
  WAREHOUSE = my_wh
  SCHEDULE = '10 minute'
  USER_TASK_TIMEOUT_MS = 14400000
AS
  ALTER DATABASE mydb REFRESH;

-- Start task
ALTER TASK my_refresh_task RESUME;

레거시 계정 로케이터 사용하기¶

현재는 복제 및 장애 조치 명령에서 계정을 식별할 때 레거시 snowflake_region.account_locator 형식이 지원되지만, 앞으로는 작동이 중지될 수 있으므로 사용하지 않는 것이 좋습니다.

보조 데이터베이스에서 실행됨¶

1. 보조 데이터베이스에서 DATABASE_REFRESH_PROGRESS 테이블 함수(Snowflake Information Schema)를 쿼리합니다. PRIMARY_UPLOADING_DATA 단계에 대한 DETAILS 열에서 snapshot_transaction_timestamp 를 기록합니다. 기본 데이터베이스의 최신 스냅샷에 대한 타임스탬프입니다.

   select parse_json(details)['snapshot_transaction_timestamp']
   from table(information_schema.database_refresh_progress(mydb))
   where phase_name = 'PRIMARY_UPLOADING_DATA';
   

   Copy

2. 지정된 테이블에 대해 HASH_AGG 함수를 쿼리합니다. 다음 쿼리는 mytable 테이블의 모든 행에 대한 해시 값을 반환합니다.

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

기본 데이터베이스에서 실행됨¶

3. 기본 데이터베이스에서 동일한 테이블에 대해 HASH_AGG 함수를 쿼리합니다. Time Travel을 사용하여 보조 데이터베이스에 대한 최신 스냅샷이 생성된 타임스탬프를 지정합니다.

   SELECT HASH_AGG( * ) FROM mytable AT(TIMESTAMP => '<snapshot_transaction_timestamp>'::TIMESTAMP);
   

   Copy

4. 두 쿼리의 결과를 비교합니다. 출력은 동일해야 합니다.