- スキーマ:
REPLICATION_GROUP_REFRESH_HISTORY ビュー¶
このAccount Usageビューを使用すると、指定された 複製またはフェールオーバーグループ の更新履歴をクエリできます。
- こちらもご参照ください。
REPLICATION_GROUP_REFRESH_HISTORY (情報スキーマ表関数)
列¶
列名 |
データ型 |
説明 |
---|---|---|
REPLICATION_GROUP_NAME |
TEXT |
セカンダリ複製またはフェールオーバーグループの名前。 |
REPLICATION_GROUP_ID |
NUMBER |
複製またはフェールオーバーグループのための内部/システムで生成された識別子。 |
PHASE_NAME |
TEXT |
複製操作の現在のフェーズ。フェーズのリストについては、 使用上の注意 をご参照ください。 |
START_TIME |
TIMESTAMP_LTZ |
複製操作が開始された時刻。 |
END_TIME |
TIMESTAMP_LTZ |
複製操作が終了した時刻(該当する場合)。進行中の場合は |
JOB_UUID |
TEXT |
更新ジョブのクエリ ID。 |
TOTAL_BYTES |
VARIANT |
更新されたデータベースに関する詳細情報を提供する JSON オブジェクト:
|
OBJECT_COUNT |
VARIANT |
更新されたオブジェクトに関する詳細情報を提供する JSON オブジェクト:
|
PRIMARY_SNAPSHOT_TIMESTAMP |
TIMESTAMP_LTZ |
プライマリスナップショットが作成されたときのタイムスタンプ。 |
ERROR |
VARIANT |
更新操作に成功した場合は NULL。更新操作に失敗した場合は、エラーに関する詳細情報を提供する JSON オブジェクトを返します。
|
使用上の注意¶
このビューの待機時間は最大180分(3時間)です。
更新の進捗状況をリアルタイムで表示するには、 REPLICATION_GROUP_REFRESH_HISTORY テーブル関数を使用します。
結果は、現在のアカウント(ターゲットアカウント)内にあるセカンダリフェールオーバーグループまたは複製グループに対してのみ返されます。
次は、処理される順序のフェーズのリストです。
#
フェーズ名
説明
1
SECONDARY_SYNCHRONIZING_MEMBERSHIP
セカンダリ複製グループまたはフェイルオーバーグループが、グループに含まれるオブジェクトに関する情報をプライマリグループから受け取り、そのメンバーシップメタデータを更新します。
2
SECONDARY_UPLOADING_INVENTORY
セカンダリ複製またはフェイルオーバーグループが、ターゲットアカウント内のオブジェクトのインベントリを、プライマリグループに送信します。
3
PRIMARY_UPLOADING_METADATA
プライマリ複製グループまたはフェイルオーバーグループが、ソースアカウントのメタデータのスナップショットを作成し、セカンダリグループに送信します。
4
PRIMARY_UPLOADING_DATA
プライマリ複製グループまたはフェイルオーバーグループが、セカンダリグループがソースアカウントとターゲットアカウントのオブジェクト間の差分を調整するために使用するファイルをコピーします。
5
SECONDARY_DOWNLOADING_METADATA
セカンダリ複製グループまたはフェイルオーバーグループが、プライマリから送信されたメタデータのスナップショットを適用します。メタデータの更新はアトミックに適用されるのではなく、時間をかけて適用されます。
6
SECONDARY_DOWNLOADING_DATA
セカンダリ複製グループまたはフェイルオーバーグループが、プライマリグループから送信されたファイルをターゲットアカウントにコピーします。
7
COMPLETED
/FAILED
/CANCELED
更新処理のステータス。
例¶
セカンダリフェイルオーバーグループ myfg
の更新履歴を取得するには、以下のステートメントを実行します:
SELECT phase_name, start_time, end_time,
total_bytes, object_count, error
FROM SNOWFLAKE.ACCOUNT_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
WHERE replication_group_name = 'MYFG';
各複製グループまたはフェイルオーバーグループの最後の更新記録を取得するには、以下のステートメントを実行します:
SELECT replication_group_name, phase_name,
start_time, end_time,
total_bytes, object_count, error,
ROW_NUMBER() OVER (
PARTITION BY replication_group_name
ORDER BY end_time DESC
) AS row_num
FROM SNOWFLAKE.ACCOUNT_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
QUALIFY row_num = 1;