TiDBBinlogクラスターの操作
このドキュメントでは、次のTiDBBinlogクラスタ操作を紹介します。
- ポンプノードとドレイナーノードの状態
- ポンプまたはドレイナープロセスの開始または終了
- binlogctlツールを使用するか、TiDBでSQL操作を直接実行することによるTiDBBinlogクラスタの管理
ポンプまたはドレイナーの状態
ポンプまたはドレイナーの状態の説明:
online:正常に動作していますpausing:一時停止中paused:停止しましたclosing:オフラインプロセス中offline:オフラインになっています
ノート:
ポンプノードまたはドレイナーノードの状態情報は、サービス自体によって維持され、配置ドライバー(PD)に定期的に更新されます。
ポンプまたはドレイナープロセスの開始と終了
ポンプ
- 開始:開始すると、ポンプノードは
online状態のすべてのドレイナーノードに通知します。通知が成功すると、Pumpノードはその状態をonlineに設定します。それ以外の場合、Pumpノードはエラーを報告し、その状態をpausedに設定して、プロセスを終了します。 - 終了:プロセスが正常に終了する前に、ポンプノードは
pausedまたはofflineの状態になります。プロセスが異常終了した場合(kill -9コマンド、プロセスパニック、クラッシュが原因)、ノードはonline状態のままです。- 一時停止:
killコマンド(kill -9ではなく)を使用するか、 Ctrl + Cを押すか、binlogctlツールのpause-pumpコマンドを使用して、Pumpプロセスを一時停止できます。一時停止命令を受信した後、Pumpノードはその状態をpausingに設定し、binlog書き込み要求の受信を停止し、Drainerノードへのbinlogデータの提供を停止します。すべてのスレッドが安全に終了した後、Pumpノードはその状態をpausedに更新し、プロセスを終了します。 - オフライン:binlogctlツールの
offline-pumpコマンドを使用することによってのみ、Pumpプロセスを閉じることができます。オフライン命令を受信した後、Pumpノードはその状態をclosingに設定し、binlog書き込み要求の受信を停止します。 Pumpノードは、すべてのbinlogデータがDrainerノードによって消費されるまで、Drainerノードにbinlogを提供し続けます。次に、Pumpノードはその状態をofflineに設定し、プロセスを終了します。
- 一時停止:
ドレイナー
- 開始:開始すると、Drainerノードはその状態を
onlineに設定し、offline状態ではないすべてのPumpノードからbinlogをプルしようとします。 binlogの取得に失敗した場合は、試行を続けます。 - 終了:プロセスが正常に終了する前に、Drainerノードは
pausedまたはofflineの状態になります。プロセスが異常終了した場合(kill -9、プロセスパニック、クラッシュが原因)、Drainerノードはonline状態のままです。- 一時停止:
killコマンド(kill -9ではなく)を使用するか、 Ctrl + Cを押すか、binlogctlツールのpause-drainerコマンドを使用して、Drainerプロセスを一時停止できます。一時停止命令を受け取った後、Drainerノードはその状態をpausingに設定し、Pumpノードからのbinlogのプルを停止します。すべてのスレッドが安全に終了した後、Drainerノードはその状態をpausedに設定し、プロセスを終了します。 - オフライン:binlogctlツールの
offline-drainerコマンドを使用することによってのみ、Drainerプロセスを閉じることができます。オフライン命令を受け取った後、Drainerノードはその状態をclosingに設定し、Pumpノードからのbinlogのプルを停止します。すべてのスレッドが安全に終了した後、Drainerノードはその状態をofflineに更新し、プロセスを終了します。
- 一時停止:
Drainerの状態を一時停止、閉じる、確認、および変更する方法については、 binlogctlガイドを参照してください。
binlogctlを使用してPump/ binlogctlを管理します
binlogctlは、次の機能を備えたTiDBBinlogの操作ツールです。
- ポンプまたはドレイナーの状態を確認する
- ポンプまたはドレイナーの一時停止または閉鎖
- ポンプまたはドレイナーの異常状態への対応
binlogctlの詳細な使用法については、 binlogctlの概要を参照してください。
SQLステートメントを使用してPumpまたはDrainerを管理する
binlog関連の状態を表示または変更するには、TiDBで対応するSQLステートメントを実行します。
binlogが有効になっているかどうかを確認します。
show variables like "log_bin";+---------------+-------+ | Variable_name | Value | +---------------+-------+ | log_bin | 0 | +---------------+-------+値が
0の場合、binlogが有効になります。値が1の場合、binlogは無効になります。すべてのポンプノードまたはドレイナーノードのステータスを確認します。
show pump status;+--------|----------------|--------|--------------------|---------------------| | NodeID | Address | State | Max_Commit_Ts | Update_Time | +--------|----------------|--------|--------------------|---------------------| | pump1 | 127.0.0.1:8250 | Online | 408553768673342237 | 2019-05-01 00:00:01 | +--------|----------------|--------|--------------------|---------------------| | pump2 | 127.0.0.2:8250 | Online | 408553768673342335 | 2019-05-01 00:00:02 | +--------|----------------|--------|--------------------|---------------------|show drainer status;+----------|----------------|--------|--------------------|---------------------| | NodeID | Address | State | Max_Commit_Ts | Update_Time | +----------|----------------|--------|--------------------|---------------------| | drainer1 | 127.0.0.3:8249 | Online | 408553768673342532 | 2019-05-01 00:00:03 | +----------|----------------|--------|--------------------|---------------------| | drainer2 | 127.0.0.4:8249 | Online | 408553768673345531 | 2019-05-01 00:00:04 | +----------|----------------|--------|--------------------|---------------------|異常な状況でポンプまたはドレイナーノードの状態を変更します
change pump to node_state ='paused' for node_id 'pump1';Query OK, 0 rows affected (0.01 sec)change drainer to node_state ='paused' for node_id 'drainer1';Query OK, 0 rows affected (0.01 sec)上記のSQLステートメントの実行は、binlogctlの
update-pumpまたはupdate-drainerコマンドと同じように機能します。上記のSQLステートメントは、PumpノードまたはDrainerノードが異常な状況にある場合にのみ使用してください。
ノート:
- binlogが有効になっているかどうか、およびポンプまたはドレイナーの実行ステータスがTiDBv2.1.7以降のバージョンでサポートされているかどうかを確認します。
- ポンプまたはドレイナーのステータスの変更は、TiDBv3.0.0-rc.1以降のバージョンでサポートされています。この機能は、PDに保存されているポンプノードまたはドレイナーノードのステータスの変更のみをサポートします。ノードを一時停止または閉じるには、
binlogctlツールを使用します。