データソース構成の管理

このドキュメントでは、MySQLパスワードの暗号化、データソースの操作、 dmctlを使用したアップストリームMySQLインスタンスとDMワーカー間のバインディングの変更など、データソース構成を管理する方法を紹介します。

データベースのパスワードを暗号化する

DM構成ファイルでは、dmctlで暗号化されたパスワードを使用することをお勧めします。 1つの元のパスワードの場合、暗号化されたパスワードは暗号化ごとに異なります。

./dmctl -encrypt 'abc!@#123'

MKxn0Qo3m3XOyjCnhEMtsUCm83EhGQDZ/T4=

データソースを操作する

operate-sourceコマンドを使用して、データソース構成をDMクラスタにロード、リスト、または削除できます。

help operate-source

`create`/`update`/`stop`/`show` upstream MySQL/MariaDB source.

Usage:
  dmctl operate-source  [config-file ...] [--print-sample-config] [flags]

Flags:
  -h, --help                  help for operate-source
  -p, --print-sample-config   print sample config file of source

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

フラグの説明

• create ：1つ以上のアップストリームデータベースソースを作成します。複数のデータソースの作成に失敗すると、DMはコマンドが実行されなかった状態にロールバックします。

• update ：アップストリームデータベースソースを更新します。

• stop ：1つ以上のアップストリームデータベースソースを停止します。複数のデータソースの停止に失敗すると、一部のデータソースが停止する場合があります。

• show ：追加されたデータソースと対応するDMワーカーを表示します。

• config-file ： source.yamlのファイルパスを指定し、複数のファイルパスを渡すことができます。

• --print-sample-config ：サンプル設定ファイルを出力します。このパラメーターは他のパラメーターを無視します。

使用例

次のoperate-sourceのコマンドを使用して、ソース構成ファイルを作成します。

operate-source create ./source.yaml

source.yamlの構成については、 アップストリームデータベースConfiguration / コンフィグレーションファイルの概要を参照してください。

返される結果の例を次に示します。

{
    "result": true,
    "msg": "",
    "sources": [
        {
            "result": true,
            "msg": "",
            "source": "mysql-replica-01",
            "worker": "dm-worker-1"
        }
    ]
}

データソース構成を確認する

ノート：

get-configコマンドは、DMv2.0.1以降のバージョンでのみサポートされます。

source-idがわかっている場合は、 dmctl --master-addr <master-addr> get-config source <source-id>を実行してデータソース構成を取得できます。

get-config source mysql-replica-01

{
  "result": true,
    "msg": "",
    "cfg": "enable-gtid: false
      flavor: mysql
      source-id: mysql-replica-01
      from:
        host: 127.0.0.1
        port: 8407
        user: root
        password: '******'
}

source-idがわからない場合は、 dmctl --master-addr <master-addr> operate-source showを実行して、最初にすべてのデータソースを一覧表示できます。

operate-source show

{
    "result": true,
    "msg": "",
    "sources": [
        {
            "result": true,
            "msg": "source is added but there is no free worker to bound",
            "source": "mysql-replica-02",
            "worker": ""
        },
        {
            "result": true,
            "msg": "",
            "source": "mysql-replica-01",
            "worker": "dm-worker-1"
        }
    ]
}

アップストリームのMySQLインスタンスとDMワーカー間のバインディングを変更します

transfer-sourceコマンドを使用して、アップストリームのMySQLインスタンスとDMワーカー間のバインディングを変更できます。

help transfer-source

Transfers an upstream MySQL/MariaDB source to a free worker.
Usage:
  dmctl transfer-source   [flags]
Flags:
  -h, --help   help for transfer-source
Global Flags:
  -s, --source strings   MySQL Source ID.

転送する前に、DMは、バインド解除されるワーカーにまだ実行中のタスクがあるかどうかを確認します。ワーカーに実行中のタスクがある場合は、最初にタスクを一時停止しますを実行し、バインディングを変更してからタスクを再開するを実行する必要があります。

使用例

DMワーカーのバインディングがわからない場合は、 dmctl --master-addr <master-addr> list-member --workerを実行して、すべてのワーカーの現在のバインディングを一覧表示できます。

list-member --worker

{
    "result": true,
    "msg": "",
    "members": [
        {
            "worker": {
                "msg": "",
                "workers": [
                    {
                        "name": "dm-worker-1",
                        "addr": "127.0.0.1:8262",
                        "stage": "bound",
                        "source": "mysql-replica-01"
                    },
                    {
                        "name": "dm-worker-2",
                        "addr": "127.0.0.1:8263",
                        "stage": "free",
                        "source": ""
                    }
                ]
            }
        }
    ]
}

上記の例では、 mysql-replica-01はdm-worker-1にバインドされています。次のコマンドは、 mysql-replica-01からdm-worker-2のバインディングワーカーを転送します。

transfer-source mysql-replica-01 dm-worker-2

{
    "result": true,
    "msg": ""
}

dmctl --master-addr <master-addr> list-member --workerを実行して、コマンドが有効になるかどうかを確認します。

list-member --worker

{
    "result": true,
    "msg": "",
    "members": [
        {
            "worker": {
                "msg": "",
                "workers": [
                    {
                        "name": "dm-worker-1",
                        "addr": "127.0.0.1:8262",
                        "stage": "free",
                        "source": ""
                    },
                    {
                        "name": "dm-worker-2",
                        "addr": "127.0.0.1:8263",
                        "stage": "bound",
                        "source": "mysql-replica-01"
                    }
                ]
            }
        }
    ]
}