アカウントオブジェクトの複製¶

ソースアカウントでの実行¶

1. ロールを作成し、それに CREATE FAILOVER GROUP 権限を付与します。このステップは オプション です。

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
    TO ROLE myrole;
   

   Copy

2. ソースアカウントにフェールオーバーグループを作成し、特定のターゲットアカウントへの複製を有効にします。

   注釈

   • 以前に ALTER DATABASE を使用して、データベースの複製とフェールオーバーが有効になっている複製またはフェールオーバーグループに追加するデータベースがある場合は、グループに追加する前に、 データベース複製からグループベース複製への移行 （このトピック内）の手順に従います。

   • データベースをフェールオーバーグループに追加するには、データベースに対する MONITOR 権限がアクティブなロールに必要です。データベース権限の詳細については、 データベース権限 （別のトピック内）をご参照ください。

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       OBJECT_TYPES = USERS, ROLES, WAREHOUSES, RESOURCE MONITORS, DATABASES
       ALLOWED_DATABASES = db1, db2
       ALLOWED_ACCOUNTS = myorg.myaccount2, myorg.myaccount3
       REPLICATION_SCHEDULE = '10 MINUTE';
   

   Copy

   注意

   複製中に ドロップしたくない アカウントオブジェクト（例: ユーザーまたはロール）がターゲットアカウントに存在する場合は、複製またはフェールオーバーグループの作成時に REPLICATION_SCHEDULE パラメーターを 含めない でください。詳細については、 ステップ5:ターゲットアカウントのスクリプトによって作成されたオブジェクトにグローバル IDs を適用する --- オプション をご参照ください。

ターゲットアカウントでの実行¶

3. ターゲットアカウントにロールを作成し、それに CREATE FAILOVER GROUP 権限を付与します。このステップは オプション です。

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
       TO ROLE myrole;
   

   Copy

4. ソースアカウントのフェールオーバーグループのレプリカとして、ターゲットアカウントにフェールオーバーグループを作成します。

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       AS REPLICA OF myorg.myaccount1.myfg;
   

   Copy

5. グローバル IDs をオブジェクトに適用します。これは、複製を介して作成されて いない アカウントオブジェクトに対する オプション のステップです。

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');
   

   Copy

   注意

   複製中に ドロップしたくない アカウントオブジェクト（例: ユーザーまたはロール）がターゲットアカウントに存在する場合は、このステップを実行する必要があります。この手順を実行しないと、ユーザーワークシートが失われたり、オブジェクト（例: 共有など）のロールに付与された権限が失われる可能性があります。詳細については、 ステップ5:ターゲットアカウントのスクリプトによって作成されたオブジェクトにグローバル IDs を適用する --- オプション をご参照ください。

セカンダリグループを手動で更新する¶

ターゲットアカウントのセカンダリフェールオーバーグループを手動で更新するには、 ターゲットアカウント内のセカンダリフェールオーバーグループの手動更新 （このトピック内）をご参照ください。

ストリームとタスクの複製のプレビューを有効にする --- オプション¶

アカウント、データベース、複製またはフェールオーバーグループのストリーム複製とタスク複製のプレビューを有効にするには、ソースアカウントまたはプライマリオブジェクトの ENABLE_STREAM_TASK_REPLICATION パラメーターを true に設定します。

alter database mydb set ENABLE_STREAM_TASK_REPLICATION = true;

alter replication group myrg set ENABLE_STREAM_TASK_REPLICATION = true;

alter account myorg.myaccount set ENABLE_STREAM_TASK_REPLICATION = true;

複製が有効になっているすべてのアカウントを表示する¶

複製が有効になっている組織内のアカウントのリストを取得するには、 SHOW REPLICATION ACCOUNTS を使用します。

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SHOW REPLICATION ACCOUNTS;

+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| snowflake_region       | created_on              | account_name | account_locator |  comment        | organization_name |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_WEST_2          | 2020-07-15 21:59:25.455 | myaccount1   | myacctlocator1  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_1          | 2020-07-23 14:12:23.573 | myaccount2   | myacctlocator2  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_2          | 2020-07-25 19:25:04.412 | myaccount3   | myacctlocator3  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+

地域 IDs の包括的なリストをご参照ください。

フェールオーバーと複製グループのメンバーシップを表示する¶

アカウント、データベース、および共有オブジェクトには、 グループメンバーシップの制約 があります。新しいグループを作成したり、既存のグループにオブジェクトを追加したりする前に、既存のフェールオーバーグループと各グループのオブジェクトのリストを確認できます。

現在のアカウントにリンクされているすべてのフェールオーバーグループと、各グループのオブジェクト型を表示します。

SHOW FAILOVER GROUPS;

Copy

フェールオーバーグループ myfg 内のすべてのデータベースを表示します。

SHOW DATABASES IN FAILOVER GROUP myfg;

Copy

フェールオーバーグループ myfg 内のすべての共有を表示します。

SHOW SHARES IN FAILOVER GROUP myfg;

Copy

ソースアカウントからターゲットアカウントへのアカウントおよびデータベースオブジェクトの複製を有効にする¶

ソースアカウントに指定されたアカウントとデータベースオブジェクトのフェールオーバーグループを作成し、ターゲットアカウントのリストへの複製とフェールオーバーを有効にします。構文については、 CREATE FAILOVER GROUP をご参照ください。

たとえば、同じ組織内のソースアカウントから myaccount2 アカウントへのユーザー、ロール、ウェアハウス、リソースモニター、およびデータベース db1 および db2 の複製を有効にします。10分ごとに myaccount2 を自動的に更新するように複製スケジュールを設定します。

ソースアカウントで実行:

use role myrole;

-- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
create failover group myfg
    object_types = users, roles, warehouses, resource monitors, databases, integrations, network policies
    allowed_databases = db1, db2
    allowed_integration_types = API INTEGRATIONS
    allowed_accounts = myorg.myaccount2
    replication_schedule = '10 MINUTE';

複製スケジュールを使用しない複製グループまたはフェールオーバーグループの作成¶

複製スケジュールを持つプライマリ複製またはフェールオーバーグループのレプリカとして、セカンダリ複製またはフェールオーバーグループを作成すると、セカンダリ複製またはフェールオーバーグループの作成時に、セカンダリグループの初期更新が自動的に実行されます。次の手順を実行する前にこれが発生しないようにするには、 REPLICATION_SCHEDULE パラメーターを設定せずにプライマリ複製またはフェールオーバーグループを作成します。

ターゲットアカウントにセカンダリグループが作成されたら、 SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME 関数を使用して、グローバル識別子をターゲットアカウントのアカウントオブジェクトに追加します。ターゲットアカウントに のみ 存在するアカウントオブジェクトの場合は、この関数を呼び出す前に、手動でソースアカウントに複製します。

ターゲットアカウントのオブジェクトにグローバル識別子を適用するか、ソースアカウントでそれらを手動で再作成した後、 ALTER REPLICATION GROUP または ALTER FAILOVER GROUP コマンドを使用して、プライマリ複製またはフェールオーバーグループの複製スケジュールを設定します。

SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME() を使用してグローバル IDs を適用する¶

グローバル識別子を、フェールオーバーグループ myfg の object_types リストに含まれる型のターゲットアカウント内にあるアカウントオブジェクトに適用します。

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');

例¶

フェールオーバーグループ myfg に対する最新の更新操作の進行状況を表示します。

SELECT PHASE_NAME, START_TIME, END_TIME, PROGRESS, DETAILS
  FROM TABLE(information_schema.replication_group_refresh_progress('myfg'));

例¶

Information Schema REPLICATION_GROUP_REFRESH_HISTORY テーブル関数をクエリして、過去7日間のフェールオーバーグループ myfg のアカウント複製履歴を表示します。

SELECT PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM TABLE(information_schema.replication_group_refresh_history('myfg'))
  WHERE START_TIME >= current_date - interval '7 days';

Account Usage REPLICATION_GROUP_REFRESH_HISTORY ビューをクエリして、当月のアカウント複製履歴を表示します。

SELECT REPLICATION_GROUP_NAME, PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM snowflake.account_usage.replication_group_refresh_history
  WHERE START_TIME >= date_trunc('month', current_date());

例¶

REPLICATION_GROUP_USAGE_HISTORY テーブル関数をクエリして、過去7日間にアカウントの複製に使用されたクレジットを表示します。

SELECT start_time, end_time, replication_group_name, credits_used, bytes_transferred
  FROM table(information_schema.replication_group_usage_history(date_range_start=>dateadd('day', -7, current_date())));

Account Usage REPLICATION_GROUP_USAGE_HISTORY ビューをクエリして、当月内にアカウント複製履歴のために、複製またはフェールオーバーグループによって使用されたクレジットを表示します。

SELECT start_time, 
  end_time, 
  replication_group_name, 
  credits_used, 
  bytes_transferred
FROM snowflake.account_usage.replication_group_usage_history
WHERE start_time >= DATE_TRUNC('month', CURRENT_DATE());

例¶

ターゲットアカウントでの実行¶

1. REPLICATION_GROUP_REFRESH_PROGRESS テーブル関数（Snowflake Information Schema 内）をクエリします。 PRIMARY_UPLOADING_METADATA フェーズの DETAILS 列にある primarySnapshotTimestamp に注意してください。これは、プライマリデータベースの最新スナップショットのタイムスタンプです。

   SELECT PARSE_JSON(details)['primarySnapshotTimestamp']
     FROM TABLE(information_schema.replication_group_refresh_progress('myfg'))
     WHERE PHASE_NAME = 'PRIMARY_UPLOADING_METADATA';
   

   Copy

2. セカンダリデータベースにある指定されたテーブルの HASH_AGG 関数をクエリします。次のクエリは、 mytable テーブル内にあるすべての行のハッシュ値を返します。

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

ソースアカウントでの実行¶

3. プライマリデータベースにある同じテーブルの HASH_AGG 関数をクエリします。Time Travelを使用して、セカンダリデータベースの最新のスナップショットが作成されたときのタイムスタンプを指定します。

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

   Copy

4. 2つのクエリの結果を比較します。出力は同一である必要があります。