アカウントオブジェクトのフェールオーバー¶

Prerequisites¶

1. 同じ組織内の一連のアカウントで、1つのクラウドサービスプロバイダーの複数のリージョン間での、または異なるクラウドサービスプロバイダー間での、複製を有効にします。

2. 複製するオブジェクトの種類を定義し、複製先のターゲットアカウントを指定する、プライマリフェールオーバーグループを作成します。たとえば、一部のデータベースを他のデータベースよりも頻繁に複製する必要がある場合などには、複製されたオブジェクトを複数のフェールオーバーグループに分割することができます。

3. Create at least one secondary failover group (replica) of each primary failover group in one or more secondary accounts.

4. フェールオーバーグループ内のオブジェクトに対する最新の更新で、各レプリカをリフレッシュ（同期）します。初期リフレッシュを実行し、各セカンダリアカウントに最新の変更を定期的に反映するスケジュールを設定します。

For instructions, see アカウントオブジェクトとデータベースの複製.

ソースアカウントとして使用するターゲットアカウントの昇格¶

Snowsight または SQL を使用して、ターゲットアカウントをソースアカウントに昇格させることができます（フェールオーバー）。

For more information about the kinds of objects you can specify in a failover group, see 複製グループとフェールオーバーグループ.

Replication group "<GROUP_NAME>" cannot currently be set as primary because it is being
refreshed. Either wait for the refresh to finish or cancel the refresh and try again.

ALTER FAILOVER GROUP myfg RESUME;

進行中のリフレッシュ操作の現在のフェーズの表示¶

リフレッシュ操作は、リフレッシュ操作のほとんどの段階で安全にキャンセルすることができます。ただし、 SECONDARY_DOWNLOADING_METADATA または SECONDARY_DOWNLOADING_DATA フェーズでリフレッシュ操作をキャンセルすると、ターゲットアカウントの状態が一貫しなくなる可能性があります。 リフレッシュ操作がこれらのフェーズのいずれかを開始した場合、ソースアカウントの可用性に関係なく、完了まで進みます。フェールオーバーする前にフェーズを完了させることで、レプリカが一貫した状態になるようにします。レプリカが一貫性のある状態になったら、インジェストおよび変換パイプラインを再開または再生して、レプリカを現在の状態に更新できます。

フェールオーバーグループの進行中のリフレッシュ操作の現在のフェーズを表示するには、Information Schema REPLICATION_GROUP_REFRESH_PROGRESS, REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB, REPLICATION_GROUP_REFRESH_PROGRESS_ALL テーブル関数を使用します。

例えば、フェールオーバーグループ myfg の進行中のリフレッシュ操作の現在のフェーズを表示するには、以下の文を実行します。

SELECT phase_name, start_time, end_time
  FROM TABLE(
    INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS('myfg')
  );

リフレッシュ操作のフェーズのリストについては、その関数の 使用上の注意 をご参照ください。

自動的にスケジュールされなかった、進行中のリフレッシュ操作をキャンセルします。¶

複製スケジュールによって自動的にトリガーされなかった進行中のリフレッシュ操作をキャンセルするには、 SYSTEM$CANCEL_QUERY 関数を使用する必要があります。

1. 以下のオプションのいずれかを使用して、リフレッシュ処理を実行するクエリIDまたはJOB_UUIDを検索します。

   1. 実行中のすべてのリフレッシュ操作のクエリIDsを検索します。

      SELECT query_id, query_text
        FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY())
        WHERE query_type = 'REFRESH REPLICATION GROUP'
        AND execution_status = 'RUNNING'
        ORDER BY start_time;
      

      Copy

      QUERY_TEXT列を使用して、リストからフェールオーバーグループのリフレッシュ操作用のQUERY_IDを識別します。

   2. 特定のフェールオーバーグループ myfg の進行中のリフレッシュ操作の JOB_UUID を検索します。

      SELECT phase_name, start_time, job_uuid
        FROM TABLE(INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_HISTORY('myfg'))
        WHERE phase_name <> 'COMPLETED' and phase_name <> 'CANCELED';
      

      Copy

2. SYSTEM$CANCEL_QUERY 関数と QUERY_ID または JOB_UUID を使用して、リフレッシュ操作をキャンセルします。

   SELECT SYSTEM$CANCEL_QUERY('<QUERY_ID | JOB_UUID>');
   

   Copy

   次の出力を返します。

   query [<QUERY_ID>] terminated.
   

3. 進行中のリフレッシュ操作をキャンセルしたら、 次のステップ に進みます。

Snowpipe Streamingのためのアクティブチャネルを新しく昇格したソースアカウントで再度開く¶

Snowpipe Streamingによって 投入されたプライマリデータベースのテーブルは、セカンダリデータベースに複製されます。フェールオーバー後、テーブルのアクティブなSnowpipe Streamingチャネルを再度開き、チャネルの不足しているデータ行を再挿入します。

1. openChannel API を呼び出して、テーブルのアクティブチャネルを再度開きます。

2. オフセットトークンをフェッチします。

   1. getLatestCommittedOffsetToken API を呼び出す、 または

   2. SHOW CHANNELS コマンドを実行し、テーブルのアクティブチャネルのリストを取得します。

3. フェッチしたオフセットトークンからチャネルのデータ行を再挿入します。