跳到主要内容
版本：0.8

Region Migration

Region 迁移允许用户在 Datanode 间移动 Region 数据。

注意

该功能仅在 GreptimeDB 集群模式下可用，并且需要满足以下条件

  • 使用 Kafka WAL
  • 使用共享存储 (例如：AWS S3)

无法在任何上述以外的情况下使用 Region 迁移。

查询 Region 分布​

首先需要查询该数据表分区（Region）分布情况，即查询数据表中的 Region 分别在哪一些 Datanode 节点上。

select b.peer_id as datanode_id,
       a.greptime_partition_id as region_id
from information_schema.partitions a left join information_schema.region_peers b
on a.greptime_partition_id = b.region_id where a.table_name='migration_target' order by datanode_id asc;

例如：有以下的 Region 分布

+-------------+---------------+
| datanode_id | region_id     |
+-------------+---------------+
|           1 | 4398046511104 |
+-------------+---------------+
1 row in set (0.01 sec)

更多关于 region_peers 表的信息，请阅读 REGION-PEERS。

选择 Region 迁移的目标节点​

Warning

当起始节点等于目标节点时，Region 迁移不会被执行

如果你通过 GreptimeDB operator 部署 DB 集群，Datanode 的 peer_id 总是从 0 开始递增。例如，DB 集群有 3 个 Datanode，则 peer_id 应为 0,1,2。 最后，你可以通过以下 SQL 请求发起 Region 迁移请求：

select migrate_region(4398046511104, 1, 2, 60);

migrate_region 参数说明：

select migrate_region(region_id, from_peer_id, to_peer_id, replay_timeout);
OptionDescriptionRequired
region_idRegion IdRequired
from_peer_id迁移起始节点(Datanode) 的 peer id。Required
to_peer_id迁移目标节点(Datanode) 的 peer id。Required
replay_timeout迁移时回放数据的超时时间（单位：秒）。如果新 Region 未能在指定时间内回放数据，迁移将失败，旧 Region 中的数据不会丢失。Optional

查询迁移状态​

migrate_region 函数将返回执行迁移的 Procedure Id，可以通过它查询过程状态：

select procedure_state('538b7476-9f79-4e50-aa9c-b1de90710839')

如果顺利完成，将输出 JSON 格式的状态：

 {"status":"Done"}

当然，最终可以通过从 information_schema 中查询 region_peers 和 partitions 来确认 Region 分布是否符合预期。