TiDB ログ バックアップと PITRアーキテクチャ
このドキュメントでは、バックアップと復元 ( BR ) ツールを例として、TiDB ログ バックアップとポイントインタイム リカバリ (PITR) のアーキテクチャとプロセスについて説明します。
アーキテクチャ
ログ バックアップと PITR のアーキテクチャは次のとおりです。
ログバックアップのプロセス
クラスター ログ バックアップのプロセスは次のとおりです。
ログ バックアップ プロセスに関係するシステム コンポーネントと主要な概念:
- ローカル メタデータ: ローカル チェックポイント ts、グローバル チェックポイント ts、バックアップ ファイル情報など、単一の TiKV ノードによってバックアップされたメタデータを示します。
- ローカル チェックポイント ts (ローカル メタデータ内): この TiKV ノードのローカル チェックポイント ts より前に生成されたすべてのログがターゲットstorageにバックアップされていることを示します。
- グローバル チェックポイント ts : すべての TiKV ノードのグローバル チェックポイント ts の前に生成されたすべてのログがターゲットstorageにバックアップされたことを示します。TiDB コーディネーターは、すべての TiKV ノードのローカル チェックポイント ts を収集してこのタイムスタンプを計算し、PD に報告します。
- TiDB コーディネーター: TiDB ノードがコーディネーターとして選出され、ログ バックアップ タスク全体 (グローバル チェックポイント ts) の進行状況を収集して計算する役割を担います。このコンポーネントはステートレスな設計になっており、障害が発生すると、生き残った TiDB ノードから新しいコーディネーターが選出されます。
- TiKV ログ バックアップ オブザーバー: TiDB クラスター内の各 TiKV ノードで実行され、ログ データのバックアップを担当します。TiKV ノードに障害が発生すると、そのノード上のデータ範囲のバックアップは、リージョンの再選出後に他の TiKV ノードによって引き継がれ、これらのノードはグローバル チェックポイント ts から始まる障害範囲のデータをバックアップします。
完全なバックアッププロセスは次のとおりです。
BRは
br log start
コマンドを受信します。- BR は、チェックポイント ts (ログ バックアップの開始時刻) とバックアップ タスクのstorageパスを解析します。
- ログバックアップタスクの登録: BR はPD にログバックアップタスクを登録します。
TiKV は、ログ バックアップ タスクの作成と更新を監視します。
- ログ バックアップ タスクの取得: 各 TiKV ノードのログ バックアップ オブザーバーは、PD からログ バックアップ タスクを取得し、指定された範囲のログ データをバックアップします。
ログ バックアップ オブザーバーは、KV 変更ログを継続的にバックアップします。
- KV 変更データの読み取り: KV 変更データを読み取り、変更ログをカスタム形式のバックアップファイルに保存します。
- グローバル チェックポイント ts を取得: PD からグローバル チェックポイント ts を取得します。
- ローカル メタデータの生成: ローカル チェックポイント ts、グローバル チェックポイント ts、バックアップ ファイル情報など、バックアップ タスクのローカル メタデータを生成します。
- ログ データとメタデータのアップロード: バックアップ ファイルとローカル メタデータを定期的にターゲットstorageにアップロードします。
- GC を構成する: バックアップされていないデータ (ローカル チェックポイント ts より大きい) がTiDB GC メカニズムによってリサイクルされるのを防ぐように PD に要求します。
TiDB コーディネーターは、ログ バックアップ タスクの進行状況を監視します。
- バックアップの進行状況を監視する: すべての TiKV ノードをポーリングして、各リージョン(リージョンチェックポイント ts) のバックアップの進行状況を取得します。
- グローバル チェックポイント ts を報告:リージョンチェックポイント ts に基づいてログ バックアップ タスク全体 (グローバル チェックポイント ts) の進行状況を計算し、グローバル チェックポイント ts を PD に報告します。
PD はログ バックアップ タスクのステータスを保持し、
br log status
使用してそれを表示できます。
PITRのプロセス
PITR のプロセスは次のとおりです。
完全な PITR プロセスは次のとおりです。
BRは
br restore point
コマンドを受信します。- BR は、完全バックアップ データ アドレス、ログ バックアップ データ アドレス、およびポイントインタイム リカバリ時間を解析します。
- バックアップ データ内の復元オブジェクト (データベースまたはテーブル) を照会し、復元するテーブルが存在し、復元要件を満たしているかどうかを確認します。
BR は完全なバックアップ データを復元します。
- 完全バックアップデータを復元します。スナップショットバックアップデータの復元プロセスの詳細については、 スナップショットバックアップデータを復元するを参照してください。
BR はログバックアップデータを復元します。
- バックアップ データの読み取り: ログ バックアップ データを読み取り、復元する必要があるログ バックアップ データを計算します。
- リージョン情報を取得: PD にアクセスしてすべてのリージョン分布を取得します。
- TiKV にデータの復元を要求: ログ復元要求を作成し、対応する TiKV ノードに送信します。ログ復元要求には、復元するログ バックアップ データ情報が含まれます。
TiKV はBRからの復元要求を受け入れ、ログ復元ワーカーを開始します。
- ログ復元ワーカーは、復元する必要があるログ バックアップ データを取得します。
TiKV はログ バックアップ データを復元します。
- KV のダウンロード: ログ復元ワーカーは、ログ復元要求に従って、対応するバックアップ データをバックアップstorageからローカル ディレクトリにダウンロードします。
- KV の書き換え: ログ復元ワーカーは、復元クラスター テーブルのテーブル ID に従ってバックアップ データの KV データを書き換えます。つまり、 キーバリューの元のテーブル ID を新しいテーブル ID に置き換えます。復元ワーカーは、同じ方法でインデックス ID も書き換えます。
- KV の適用: ログ復元ワーカーは、処理された KV データを raft インターフェイスを介してストア (RocksDB) に書き込みます。
- 復元結果を報告: ログ復元ワーカーは復元結果をBRに返します。
BR は各 TiKV ノードから復元結果を受信します。
RegionNotFound
またはEpochNotMatch
が原因で一部のデータの復元に失敗した場合 (たとえば、TiKV ノードがダウンしている場合)、 BR は復元を再試行します。- 復元に失敗し、再試行できないデータがある場合、復元タスクは失敗します。
- すべてのデータが復元されると、復元タスクは成功します。
ログバックアップファイル
ログ バックアップでは、次の種類のファイルが生成されます。
{min_ts}-{uuid}.log
ファイル: バックアップ タスクの KV 変更ログ データを格納します。2{min_ts}
ファイル内の KV 変更ログ データの最小 TSO タイムスタンプであり、{uuid}
はファイルの作成時にランダムに生成されます。{checkpoint_ts}-{uuid}.meta
ファイル: 各 TiKV ノードがログ バックアップ データをアップロードするたびに生成され、今回アップロードされたすべてのログ バックアップ データ ファイルのメタデータが格納されます。2{checkpoint_ts}
TiKV ノードのログ バックアップ チェックポイントであり、グローバル チェックポイントはすべての TiKV ノードの最小チェックポイントです。4{uuid}
ファイルの作成時にランダムに生成されます。{store_id}.ts
ファイル: このファイルは、各 TiKV ノードがログ バックアップ データをアップロードするたびに、グローバル チェックポイント ts で更新されます。2{store_id}
TiKV ノードのストア ID です。v1_stream_truncate_safepoint.txt
ファイル:br log truncate
によって削除されたstorage内の最新のバックアップ データに対応するタイムスタンプを保存します。
バックアップファイルの構造
.
├── v1
│ ├── backupmeta
│ │ ├── {min_restored_ts}-{uuid}.meta
│ │ ├── {checkpoint}-{uuid}.meta
│ ├── global_checkpoint
│ │ ├── {store_id}.ts
│ ├── {date}
│ │ ├── {hour}
│ │ │ ├── {store_id}
│ │ │ │ ├── {min_ts}-{uuid}.log
│ │ │ │ ├── {min_ts}-{uuid}.log
├── v1_stream_truncate_safepoint.txt
次に例を示します。
.
├── v1
│ ├── backupmeta
│ │ ├── ...
│ │ ├── 435213818858112001-e2569bda-a75a-4411-88de-f469b49d6256.meta
│ │ ├── 435214043785779202-1780f291-3b8a-455e-a31d-8a1302c43ead.meta
│ │ ├── 435214443785779202-224f1408-fff5-445f-8e41-ca4fcfbd2a67.meta
│ ├── global_checkpoint
│ │ ├── 1.ts
│ │ ├── 2.ts
│ │ ├── 3.ts
│ ├── 20220811
│ │ ├── 03
│ │ │ ├── 1
│ │ │ │ ├── ...
│ │ │ │ ├── 435213866703257604-60fcbdb6-8f55-4098-b3e7-2ce604dafe54.log
│ │ │ │ ├── 435214023989657606-72ce65ff-1fa8-4705-9fd9-cb4a1e803a56.log
│ │ │ ├── 2
│ │ │ │ ├── ...
│ │ │ │ ├── 435214102632857605-11deba64-beff-4414-bc9c-7a161b6fb22c.log
│ │ │ │ ├── 435214417205657604-e6980303-cbaa-4629-a863-1e745d7b8aed.log
│ │ │ ├── 3
│ │ │ │ ├── ...
│ │ │ │ ├── 435214495848857605-7bf65e92-8c43-427e-b81e-f0050bd40be0.log
│ │ │ │ ├── 435214574492057604-80d3b15e-3d9f-4b0c-b133-87ed3f6b2697.log
├── v1_stream_truncate_safepoint.txt