複数のアカウント間でのデータベースの複製¶

プライマリデータベースの管理¶

1. Snowsight にサインインして、プライマリデータベースを含むSnowflakeアカウントにサインインします。

2. 左上（ログイン名の横） » Switch Role » ACCOUNTADMIN のドロップダウンメニューを選択します。

3. 左側のナビゲーションペインから Data » Databases を選択します。データベースオブジェクトエクスプローラーでプライマリデータベースを選択します。データベースの詳細ページが開きます。

   あるいは、複製が有効になっているデータベースのみを表示するには、 Replication Status » Primary フィルターを使用してアカウント内のプライマリデータベースをリストします。リストからデータベースを選択し、詳細ページを開きます。

   注釈

   Replication Status フィルターは、アカウントがデータベース複製のソースアカウントまたはターゲットアカウントである場合にのみ使用できます。

4. » Enable Replication を選択します。 Enable replication ダイアログが開きます。

   実行したいアクションを選択します。

   • フェールオーバーを有効にします。この機能には Business Critical Edition （またはそれ以上）が必要です。

   • 1つ以上のターゲットアカウントにセカンダリデータベースを作成。

     別のアカウント内のプライマリデータベースが現在のアカウントへ複製できるようになっている場合は、現在のアカウント内にセカンダリデータベースを作成できます。ターゲットアカウントを追加するには、ソースアカウントで ALTER DATABASE コマンドを使用してプライマリデータベースを更新します。

   • 各セカンダリデータベースの作成後に、それぞれを1回更新。

5. このデータベースのターゲットアカウントごとに、セカンダリデータベースを作成して、データベースを更新するオプションをオンにします。

6. そのアカウントで以前に ACCOUNTADMIN ロールを付与されたユーザーとして、ターゲットアカウントにサインインします。

   Snowflakeはリクエストされたアクションを実行し、成功ダイアログを表示します。

   データベースの詳細にある Replication タブから、このデータベースの複製を管理します。

セカンダリデータベースを管理する¶

1. Snowsight にサインインして、セカンダリデータベースを含むSnowflakeアカウントにサインインします。

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 ステートメントを使用して、組織内の1つ以上のアカウントへのプライマリデータベースのフェールオーバーを有効にします。これらのアカウントのいずれか（つまり、セカンダリデータベース）にあるこのプライマリデータベースのレプリカは、プライマリデータベースとして機能するように昇格できます。

プライマリデータベースのフェールオーバーの有効化は、指定されたアカウントでプライマリデータベースのレプリカが作成された前、 または 後に行うことができます。

-- 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時間のデータ損失を許容できる場合は、少なくとも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 を使用）。複製スケジュールを指定するための CREATETASK 構文にはウェアハウスが必要ですが、ウェアハウスは複製には使用 されません。

   たとえば、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. 2つのクエリの結果を比較します。出力は同一である必要があります。