跳到主要内容
版本:0.9

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_peerspartitions 来确认 Region 分布是否符合预期。