重要

このページは英語版のページを機械翻訳しています。原文はこちらからご覧ください。

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

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

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

指示

`shard-ddl-lock`

このコマンドを使用すると、DDL ロックを表示し、指定された DDL ロックを解放するように DM マスターに要求できます。このコマンドは、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 マスターに要求します。2 [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のロックを解除するよう 1 に積極的に要求します。

注記：
現在、 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 つがあり、17 にテーブルshard_db_1 . shard_table_1とshard_db_1 . MySQL-1のshard_table_2 、27 にテーブルshard_db_2 . shard_table_1とshard_db_2 . shard_table_2の 2 つがあるとしMySQL-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(11) 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(11);"
            ],
            "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(11) NOT NULL,
  `c2` int(11) 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 ソースがデータ移行を復元する場合、非所有者は例外が発生する前に調整されていた DDL 操作の再調整を DM マスターに要求しようとし、他の 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(11);"
            ],
            "synced": [
                "mysql-replica-02"
            ],
            "unsynced": [
                "mysql-replica-01"
            ]
        }
    ]
}

shard-ddl-lock使用してDM-masterにロックを解除するように依頼します。
- ロック解除処理中に、所有者はダウンストリームへの DDL 操作を再度実行しようとします (再起動前の元の所有者はダウンストリームへの DDL 操作を 1 回実行しています)。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`