複製とフェールオーバーの監視¶

例¶

フェールオーバーグループ 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());

アカウント使用状況ビューのクエリ¶

次の例では、過去30日間における複製グループ1つのデータベース複製のコストを計算します。

1. REPLICATION_GROUP_REFRESH_HISTORY Account Usageビューをクエリして、データベースごとに複製されたバイト数の合計を計算します。

   たとえば、過去30日間に複製グループ myrg 内のデータベースで複製されたバイト数の合計を計算するには、次を実行します。

   SELECT SUM(value:totalBytesToReplicate) as sum_database_bytes
     FROM snowflake.account_usage.replication_group_refresh_history rh,
       LATERAL FLATTEN(input => rh.total_bytes:databases)
     WHERE rh.replication_group_name = 'MYRG' AND
           rh.start_time >= CURRENT_DATE() - INTERVAL '30 days';
   

   Copy

   データベースバイトの合計の出力に注意してください。

   +--------------------+
   | SUM_DATABASE_BYTES |
   |--------------------|
   |              22016 |
   +--------------------+
   

2. REPLICATION_GROUP_USAGE_HISTORY Account Usageビューをクエリして、使用されたクレジット数の合計と、複製のために転送されたバイトの合計を計算します。

   たとえば、過去30日間に使用されたクレジット数の合計と、複製グループ myrg の複製のために転送されたバイトの合計を計算するには、次を実行します。

   SELECT SUM(credits_used) AS credits_used, SUM(bytes_transferred) AS bytes_transferred
     FROM snowflake.account_usage.replication_group_usage_history
     WHERE replication_group_name = 'MYRG' AND
           start_time >= CURRENT_DATE() - INTERVAL '30 days';
   

   Copy

   使用されたクレジットの合計と転送されたバイトの合計の出力に注意してください。

   +--------------+-------------------+
   | CREDITS_USED | BYTES_TRANSFERRED |
   |--------------+-------------------|
   |  1.357923604 |             22013 |
   +--------------+-------------------+
   

3. データベースに転送されたバイトの値、使用されたクレジットの合計、および前の2つのステップから複製のために転送されたすべてのバイトの合計を使用して、データベースの複製コストを計算します。

   (<転送されたデータのバイト> / <転送されたバイト>) * <使用されたクレジット>

   例:

   (22016 / 22013) * 1.357923604 = 1.35810866)

情報スキーマテーブル関数のクエリ¶

過去14日以内の更新操作の場合は、関連するInformation Schemaテーブル関数をクエリします。

• REPLICATION_GROUP_REFRESH_HISTORY

• REPLICATION_GROUP_USAGE_HISTORY

1. REPLICATION_GROUP_REFRESH_HISTORY テーブル関数をクエリして、複製グループ myrg のデータベース複製用にコピーされたバイト数の合計を表示します。

   SELECT SUM(value:totalBytesToReplicate)
     FROM TABLE(information_schema.replication_group_refresh_history('myrg')) AS rh,
     LATERAL FLATTEN(input => total_bytes:databases)
     WHERE rh.phase_name = 'COMPLETED' AND
           rh.start_time >= CURRENT_DATE() - INTERVAL '14 days';
   

   Copy

2. REPLICATION_GROUP_USAGE_HISTORY テーブル関数をクエリして、使用されたクレジット数の合計と、複製グループ myrg の複製のために転送されたバイトの合計を表示します。

   SELECT SUM(credits_used), SUM(bytes_transferred)
     FROM TABLE(information_schema.replication_group_usage_history(
       date_range_start => DATEADD('day', -14, CURRENT_DATE()),
       replication_group_name => 'myrg'));
   

   Copy