Data Migration 多数据源汇总迁移到 TiDB

本文介绍了 DM 工具的一个简单使用场景：将三个数据源 MySQL 实例的数据迁移到一个下游 TiDB 集群中。

数据源实例

假设数据源结构为：

  • 实例 1
Schema Tables
user information, log
store store_bj, store_tj
log messages
  • 实例 2
Schema Tables
user information, log
store store_sh, store_sz
log messages
  • 实例 3
Schema Tables
user information, log
store store_gz, store_sz
log messages

迁移要求

  1. 不合并 user 库。

    1. 将实例 1 中的 user 库迁移到下游 TiDB 的 user_north 库中。

    2. 将实例 2 中的 user 库迁移到下游 TiDB 的 user_east 库中。

    3. 将实例 3 中的 user 库迁移到下游 TiDB 的 user_south 库中。

    4. 任何情况下都不删除 user.log 表的任何数据。

  2. 将数据源 store 库迁移到下游 store 库中，且迁移过程中不合并表。

    1. 实例 2 和实例 3 中都存在 store_sz 表，且这两个 store_sz 表分别被迁移到下游的 store_suzhou 表和 store_shenzhen 表中。

    2. 任何情况下都不删除 store 库的任何数据。

  3. log 库需要被过滤掉。

下游实例

假设下游结构为：

Schema Tables
user_north information, log
user_east information, log
user_south information, log
store store_bj, store_tj, store_sh, store_suzhou, store_gz, store_shenzhen

迁移方案

  • 为了满足迁移要求中第一点的前三条要求，需要配置以下 table routing 规则：

    1.   routes:
    2.     ...
    3.     instance-1-user-rule:
    4.       schema-pattern: "user"
    5.       target-schema: "user_north"
    6.     instance-2-user-rule:
    7.       schema-pattern: "user"
    8.       target-schema: "user_east"
    9.     instance-3-user-rule:
    10.       schema-pattern: "user"
    11.       target-schema: "user_south"

  • 为了满足迁移要求中第二点的第一条要求，需要配置以下 table routing 规则：

    1.   routes:
    2.     ...
    3.     instance-2-store-rule:
    4.       schema-pattern: "store"
    5.       table-pattern: "store_sz"
    6.       target-schema: "store"
    7.       target-table:  "store_suzhou"
    8.     instance-3-store-rule:
    9.       schema-pattern: "store"
    10.       table-pattern: "store_sz"
    11.       target-schema: "store"
    12.       target-table:  "store_shenzhen"

  • 为了满足迁移要求中第一点的第四条要求，需要配置以下 binlog event filter 规则：

    1.   filters:
    2.     ...
    3.     log-filter-rule:                 # 过滤掉 user.log 表的任何删除操作
    4.       schema-pattern: "user"
    5.       table-pattern: "log"
    6.       events: ["truncate table", "drop table", "delete"]
    7.       action: Ignore
    8.     user-filter-rule:                # 过滤掉删除 user 库操作
    9.       schema-pattern: "user"
    10.       events: ["drop database"]
    11.       action: Ignore

  • 为了满足迁移要求中第二点的第二条要求，需要配置以下 binlog event filter 规则：

    1.   filters:
    2.     ...
    3.     store-filter-rule:            # 过滤掉删除 store 库，以及 store 库下面任何表的所有删除操作
    4.       schema-pattern: "store"
    5.       events: ["drop database", "truncate table", "drop table", "delete"]
    6.       action: Ignore

    注意：

    store-filter-rule 不同于 log-filter-rule 和 user-filter-rule。store-filter-rule 是针对整个 store 库的规则，而 log-filter-rule 和 user-filter-rule 是针对 user 库中 log 表的规则。

  • 为了满足迁移要求中的第三点要求，需要配置以下 Block & Allow Lists：

    1.   block-allow-list:   # 通过黑白名单，过滤掉 log 库的所有操作
    2.     log-ignored:
    3.       ignore-dbs: ["log"]

迁移任务配置

以下是完整的迁移任务配置，更多详情请参阅 数据迁移任务配置向导。

  1. name: "one-tidb-slave"
  2. task-mode: all                           # 进行全量数据迁移 + 增量数据迁移
  3. meta-schema: "dm_meta"
  5. target-database:
  6.   host: "192.168.0.1"
  7.   port: 4000
  8.   user: "root"
  9.   password: ""
  11. mysql-instances:
  12.   -
  13.     source-id: "instance-1"    # 数据源对象 ID，可以从数据源配置中获取
  14.     route-rules: ["instance-1-user-rule"]  # 应用于该数据源的 table route 规则
  15.     filter-rules: ["log-filter-rule", "user-filter-rule" , "store-filter-rule"]  # 应用于该数据源的 binlog event filter 规则
  16.     block-allow-list:  "log-ignored"  # 应用于该数据源的 Block & Allow Lists 规则
  17.   -
  18.     source-id: "instance-2"
  19.     route-rules: ["instance-2-user-rule", instance-2-store-rule]
  20.     filter-rules: ["log-filter-rule", "user-filter-rule" , "store-filter-rule"]
  21.     block-allow-list:  "log-ignored"
  22.   -
  23.     source-id: "instance-3"
  24.     route-rules: ["instance-3-user-rule", instance-3-store-rule]
  25.     filter-rules: ["log-filter-rule", "user-filter-rule" , "store-filter-rule"]
  26.     block-allow-list:  "log-ignored"
  28. # 所有实例的共有配置
  30. routes:
  31.   instance-1-user-rule:
  32.     schema-pattern: "user"
  33.     target-schema: "user_north"
  34.   instance-2-user-rule:
  35.     schema-pattern: "user"
  36.     target-schema: "user_east"
  37.   instance-3-user-rule:
  38.     schema-pattern: "user"
  39.     target-schema: "user_south"
  40.   instance-2-store-rule:
  41.     schema-pattern: "store"
  42.     table-pattern: "store_sz"
  43.     target-schema: "store"
  44.     target-table:  "store_suzhou"
  45.   instance-3-store-rule:
  46.     schema-pattern: "store"
  47.     table-pattern: "store_sz"
  48.     target-schema: "store"
  49.     target-table:  "store_shenzhen"
  51. filters:
  52.   log-filter-rule:
  53.     schema-pattern: "user"
  54.     table-pattern: "log"
  55.     events: ["truncate table", "drop table", "delete"]
  56.     action: Ignore
  57.   user-filter-rule:
  58.     schema-pattern: "user"
  59.     events: ["drop database"]
  60.     action: Ignore
  61.   store-filter-rule:
  62.     schema-pattern: "store"
  63.     events: ["drop database", "truncate table", "drop table", "delete"]
  64.     action: Ignore