📣

TiDB Cloud Premium はパブリックプレビュー中です。エンタープライズワークロード向けの無制限のスケーリング、即時の弾力性、高度なセキュリティを提供します。このページは自動翻訳されたものです。原文はこちらからご覧ください。

TiDB Self-Managedについて
さあ始めましょう
デプロイ
移行
ストリームデータ
管理
監視と警告
トラブルシューティング
性能チューニング
チュートリアル
TiDBツール
参照
よくある質問

DM でシャーディング DDL ロックを手動で処理する

DMはシャーディングDDLロックを使用して、操作が正しい順序で実行されるようにします。このロック機構は、ほとんどの場合シャーディングDDLロックを自動的に解決しますが、一部の異常なシナリオでは、 shard-ddl-lockコマンドを使用して異常なDDLロックを手動で処理する必要があります。

ノート

このドキュメントは、悲観的調整モードでのシャーディング DDL ロックの処理にのみ適用されます。
このドキュメントの「コマンドの使用法」セクションに記載されているコマンドは対話型モードです。コマンドラインモードでは、エラーレポートを回避するためにエスケープ文字を追加する必要があります。
コマンドによってもたらされる可能性のある影響を完全に認識し、それを受け入れられる場合を除き、 shard-ddl-lock unlockを使用しないでください。
異常な DDL ロックを手動で処理する前に、DM シャードマージの原則を必ず読んでください。

コマンド

`shard-ddl-lock`

このコマンドを使用すると、DDLロックを表示し、DMマスターに指定されたDDLロックの解放を要求できます。このコマンドはDM v6.0以降でのみサポートされています。それより前のバージョンでは、コマンドshow-ddl-locksとunlock-ddl-locksを使用する必要があります。

shard-ddl-lock -h

maintain or show shard-ddl locks information
Usage:
  dmctl shard-ddl-lock [task] [flags]
  dmctl shard-ddl-lock [command]
Available Commands:
  unlock      Unlock un-resolved DDL locks forcely
Flags:
  -h, --help   help for shard-ddl-lock
Global Flags:
  -s, --source strings   MySQL Source ID.
Use "dmctl shard-ddl-lock [command] --help" for more information about a command.

引数の説明

shard-ddl-lock [task] [flags] : 現在の DM マスターの DDL ロック情報を表示します。

shard-ddl-lock [command] : 指定された DDL ロックを解放するように DM マスターに要求します。[command]は値としてunlockのみを受け入れます。

使用例

`shard-ddl-lock [task] [flags]`

shard-ddl-lock [task] [flags]を使用すると、現在の DM マスターの DDL ロック情報を表示できます。例:

shard-ddl-lock test

期待される出力

{
    "result": true,                                        # The result of the query for the lock information.
    "msg": "",                                             # The additional message for the failure to query the lock information or other descriptive information (for example, the lock task does not exist).
    "locks": [                                             # The existing lock information list.
        {
            "ID": "test-`shard_db`.`shard_table`",         # The lock ID, which is made up of the current task name and the schema/table information corresponding to the DDL.
            "task": "test",                                # The name of the task to which the lock belongs.
            "mode": "pessimistic"                          # The shard DDL mode. Can be set to "pessimistic" or "optimistic".
            "owner": "mysql-replica-01",                   # The owner of the lock (the ID of the first source that encounters this DDL operation in the pessimistic mode), which is always empty in the optimistic mode.
            "DDLs": [                                      # The list of DDL operations corresponding to the lock in the pessimistic mode, which is always empty in the optimistic mode.
                "USE `shard_db`; ALTER TABLE `shard_db`.`shard_table` DROP COLUMN `c2`;"
            ],
            "synced": [                                    # The list of sources that have received all sharding DDL events in the corresponding MySQL instance.
                "mysql-replica-01"
            ],
            "unsynced": [                                  # The list of sources that have not yet received all sharding DDL events in the corresponding MySQL instance.
                "mysql-replica-02"
            ]
        }
    ]
}

`shard-ddl-lock unlock`

このコマンドは、所有者に DDL ステートメントを実行するよう要求し、所有者以外の他のすべての DM ワーカーに DDL ステートメントをスキップするよう要求し、 DM-masterのロック情報を削除するなど、指定された DDL ロックを解除するようにDM-masterに積極的に要求します。

ノート

現在、 shard-ddl-lock unlockはpessimisticモードのロックに対してのみ有効です。

shard-ddl-lock unlock -h

Unlock un-resolved DDL locks forcely

Usage:
  dmctl shard-ddl-lock unlock <lock-id> [flags]

Flags:
  -a, --action string     accept skip/exec values which means whether to skip or execute ddls (default "skip")
  -d, --database string   database name of the table
  -f, --force-remove      force to remove DDL lock
  -h, --help              help for unlock
  -o, --owner string      source to replace the default owner
  -t, --table string      table name

Global Flags:
  -s, --source strings   MySQL Source ID.

shard-ddl-lock unlockは次の引数を受け入れます:

-o, --owner :
- フラグ; 文字列; オプション
- 指定されていない場合、このコマンドはデフォルトの所有者（結果shard-ddl-lockの所有者）に DDL ステートメントの実行を要求します。指定されている場合、このコマンドは MySQL ソース（デフォルトの所有者の代替）に DDL ステートメントの実行を要求します。
- 元の所有者がクラスターからすでに削除されていない限り、新しい所有者を指定しないでください。
-f, --force-remove :
- フラグ; ブール値; オプション
- 指定されていない場合、このコマンドは所有者が DDL ステートメントの実行に成功した場合にのみロック情報を削除します。指定されている場合、このコマンドは所有者が DDL ステートメントの実行に失敗してもロック情報を強制的に削除します (これを実行すると、ロックに対して再度クエリや操作を実行することはできません)。
lock-id :
- 非フラグ; 文字列; 必須
- ロック解除する必要がある DDL ロックの ID (結果shard-ddl-lockのID ) を指定します。

以下はコマンドshard-ddl-lock unlockの例です。

shard-ddl-lock unlock test-`shard_db`.`shard_table`

{
    "result": true,                                        # The result of the unlocking operation.
    "msg": "",                                             # The additional message for the failure to unlock the lock.
}

サポートされているシナリオ

現在、 shard-ddl-lock unlockコマンドは、次の 2 つの異常なシナリオでのシャーディング DDL ロックの処理のみをサポートしています。

シナリオ1: MySQLソースの一部が削除される

異常なロックの理由

DM-masterシャーディングDDLロックを自動的に解除しようとする前に、すべてのMySQLソースがシャーディングDDLイベントを受信する必要があります（詳細はシャードマージの原則を参照）。シャーディングDDLイベントが既に移行プロセス中であり、一部のMySQLソースが削除されて再ロードされない場合（これらのMySQLソースはアプリケーションの要求に応じて削除されています）、すべてのDMワーカーがDDLイベントを受信できないため、シャーディングDDLロックを自動的に移行して解除することはできません。

ノート

シャーディング DDL イベントの移行プロセス中でないときに一部の DM ワーカーをオフラインにする必要がある場合、より適切な解決策は、まずstop-taskを使用して実行中のタスクを停止し、DM ワーカーをオフラインにして、タスク構成ファイルから対応する構成情報を削除し、最後にstart-taskと新しいタスク構成を使用して移行タスクを再開することです。

手動ソリューション

アップストリームにインスタンスMySQL-1 （ mysql-replica-01 ）とMySQL-2 （ mysql-replica-02 ）の2つがあり、 MySQL-1にshard_db_1のshard_table_1とshard_db_1のshard_table_2の2つのテーブル、 MySQL-2にshard_db_2のshard_table_1とshard_db_2のshard_table_2の2つのテーブルがあるとします。ここで、これら4つのテーブルをマージして、ダウンストリームTiDBのshard_dbのshard_tableテーブルに移行する必要があります。

初期のテーブル構造は次のとおりです。

SHOW CREATE TABLE shard_db_1.shard_table_1;
+---------------+------------------------------------------+
| Table         | Create Table                             |
+---------------+------------------------------------------+
| shard_table_1 | CREATE TABLE `shard_table_1` (
  `c1` int NOT NULL,
  PRIMARY KEY (`c1`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 |
+---------------+------------------------------------------+

テーブル構造を変更するために、アップストリームのシャードテーブルで次の DDL 操作が実行されます。

ALTER TABLE shard_db_*.shard_table_* ADD COLUMN c2 INT;

MySQLとDMの操作プロセスは次のとおりです。

対応する DDL 操作がmysql-replica-01の 2 つのシャードテーブルに対して実行され、テーブル構造が変更されます。
```
ALTER TABLE shard_db_1.shard_table_1 ADD COLUMN c2 INT;
```
```
ALTER TABLE shard_db_1.shard_table_2 ADD COLUMN c2 INT;
```
DM-worker は、受信したmysql-replica-01の 2 つのシャードテーブルの DDL 情報を DM-master に送信し、DM-master は対応する DDL ロックを作成します。

現在の DDL ロックの情報を確認するには、 shard-ddl-lockを使用します。

» shard-ddl-lock test
{
    "result": true,
    "msg": "",
    "locks": [
        {
            "ID": "test-`shard_db`.`shard_table`",
            "task": "test",
            "mode": "pessimistic"
            "owner": "mysql-replica-01",
            "DDLs": [
                "USE `shard_db`; ALTER TABLE `shard_db`.`shard_table` ADD COLUMN `c2` int;"
            ],
            "synced": [
                "mysql-replica-01"
            ],
            "unsynced": [
                "mysql-replica-02"
            ]
        }
    ]
}

アプリケーションの要求により、 mysql-replica-02に対応するデータは下流の TiDB に移行する必要がなくなり、 mysql-replica-02が削除されます。
DM-masterの ID がtest-`shard_db`.`shard_table` ロックはmysql-replica-02の DDL 情報を受信できません。
- 返される結果unsynced by shard-ddl-lockには常にmysql-replica-02の情報が含まれています。
shard-ddl-lock unlockを使用してDM-masterに要求し、DDL ロックをアクティブにロック解除します。
- DDL ロックの所有者がオフラインになった場合は、パラメータ--ownerを使用して、別の DM ワーカーを新しい所有者として指定し、DDL を実行できます。
- いずれかの MySQL ソースがエラーを報告した場合、 resultがfalseに設定され、この時点で、各 MySQL ソースのエラーが許容範囲内であり、期待どおりであるかどうかを慎重に確認する必要があります。
```
shard-ddl-lock unlock test-`shard_db`.`shard_table`
```
```
{
    "result": true,
    "msg": ""
```

shard-ddl-lockを使用して、DDL ロックが正常に解除されたかどうかを確認します。

» shard-ddl-lock test
{
    "result": true,
    "msg": "no DDL lock exists",
    "locks": [
    ]
}

ダウンストリーム TiDB でテーブル構造が正常に変更されたかどうかを確認します。

mysql> SHOW CREATE TABLE shard_db.shard_table;
+-------------+--------------------------------------------------+
| Table       | Create Table                                     |
+-------------+--------------------------------------------------+
| shard_table | CREATE TABLE `shard_table` (
  `c1` int NOT NULL,
  `c2` int DEFAULT NULL,
  PRIMARY KEY (`c1`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin |
+-------------+--------------------------------------------------+

query-statusを使用して、移行タスクが正常かどうかを確認します。

インパクト

shard-ddl-lock unlockを使用して手動でロックを解除した後、タスク構成情報に含まれるオフライン MySQL ソースを処理しないと、次のシャーディング DDL イベントを受信したときにロックを自動的に移行できない可能性があります。

したがって、DDL ロックを手動でロック解除した後、次の操作を実行する必要があります。

実行中のタスクを停止するにはstop-taskを使用します。
タスク構成ファイルを更新し、構成ファイルからオフライン MySQL ソースの関連情報を削除します。
start-taskと新しいタスク構成ファイルを使用してタスクを再起動します。

ノート

shard-ddl-lock unlockを実行した後、オフラインになった MySQL ソースが再ロードされ、DM ワーカーがシャードテーブルのデータを移行しようとすると、データとダウンストリームテーブル構造の間で一致エラーが発生する可能性があります。

シナリオ2: DDLロック解除プロセス中に一部のDMワーカーが異常停止するか、ネットワーク障害が発生する

異常なロックの理由

DM-masterがすべての DM ワーカーの DDL イベントを受信した後、 unlock DDL lockが自動的に実行され、主に次の手順が含まれます。

ロックの所有者に DDL を実行し、対応するシャードテーブルのチェックポイントを更新するように依頼します。
所有者が DDL を正常に実行した後、 DM-masterに保存されている DDL ロック情報を削除します。
所有者が DDL を正常に実行した後、他のすべての非所有者に DDL をスキップし、対応するシャードテーブルのチェックポイントを更新するように依頼します。
すべての所有者または非所有者の操作が成功した後、DM マスターは対応する DDL ロック情報を削除します。

現在、上記のロック解除プロセスはアトミックではありません。非オーナーがDDL操作を正常にスキップした場合、非オーナーが配置されているDMワーカーが異常停止するか、下流のTiDBでネットワーク異常が発生し、チェックポイントの更新が失敗する可能性があります。

非所有者に対応するMySQLソースがデータ移行を復元する際、非所有者はDMマスターに対して、例外発生前に調整されていたDDL操作の再調整を要求しようとします。このため、他のMySQLソースから対応するDDL操作を受け取ることはありません。これにより、DDL操作によって対応するロックが自動的に解除される可能性があります。

手動ソリューション

ここで、上流と下流のテーブル構造が同じであり、テーブルのマージと移行に対する要求も一部のMySQLソースが削除されましたの手動ソリューションと同じであるとします。

DM-master自動的にロック解除処理を実行すると、オーナー（ mysql-replica-01 ）はDDLを正常に実行し、移行処理を継続します。しかし、非オーナー（ mysql-replica-02 ）にDDL操作のスキップを要求する処理において、対応するDMワーカーが再起動されたため、DMワーカーがDDL操作をスキップした後にチェックポイントの更新に失敗します。

mysql-replica-02に対応するデータ移行サブタスクが復元された後、DM マスターに新しいロックが作成されますが、他の MySQL ソースは DDL 操作を実行またはスキップし、後続の移行を実行しています。

操作プロセスは次のとおりです。

shard-ddl-lockを使用して、 DDL の対応するロックがDM-masterに存在するかどうかを確認します。

synced状態にあるのはmysql-replica-02だけです。

» shard-ddl-lock
{
    "result": true,
    "msg": "",
    "locks": [
        {
            "ID": "test-`shard_db`.`shard_table`",
            "task": "test",
            "mode": "pessimistic"
            "owner": "mysql-replica-02",
            "DDLs": [
                "USE `shard_db`; ALTER TABLE `shard_db`.`shard_table` ADD COLUMN `c2` int;"
            ],
            "synced": [
                "mysql-replica-02"
            ],
            "unsynced": [
                "mysql-replica-01"
            ]
        }
    ]
}

shard-ddl-lockを使用してDM-masterにロックを解除するよう依頼します。
- ロック解除プロセス中に、オーナーはダウンストリームへのDDL操作を再度実行しようとします（再起動前の元のオーナーは、ダウンストリームへのDDL操作を一度実行しています）。DDL操作が複数回実行可能であることを確認してください。
```
shard-ddl-lock unlock test-`shard_db`.`shard_table`
{
    "result": true,
    "msg": "",
}
```
shard-ddl-lockを使用して、DDL ロックが正常に解除されたかどうかを確認します。
query-statusを使用して、移行タスクが正常かどうかを確認します。

インパクト

ロックを手動で解除すると、次のシャーディング DDL を自動的かつ正常に移行できます。

DM でシャーディング DDL ロックを手動で処理する

コマンド

shard-ddl-lock

引数の説明

使用例

shard-ddl-lock [task] [flags]

shard-ddl-lock unlock

サポートされているシナリオ

シナリオ1: MySQLソースの一部が削除される

異常なロックの理由

手動ソリューション

インパクト

シナリオ2: DDLロック解除プロセス中に一部のDMワーカーが異常停止するか、ネットワーク障害が発生する

異常なロックの理由

手動ソリューション

インパクト

このページは役に立ちましたか？

`shard-ddl-lock`

`shard-ddl-lock [task] [flags]`

`shard-ddl-lock unlock`