云 InfluxDB 数据迁出方案

查看 Shard 列表

在执行备份前，通过 InfluxQL 查看所有 Shard 的信息，确定需要迁移的 Shard 范围：

SHOW SHARDS

从返回结果中获取每个 Shard 的 id、database 和 retention_policy 字段，作为后续备份命令的参数。需要对每个 Shard 分别执行备份和恢复操作。

备份 backup

在自建 InfluxDB 所在的 ECS 上执行备份命令，按 Shard 备份数据。备份需指定数据库、保留策略和 Shard ID。

• 使用方式

  influxd backup -portable \
    -host <源实例 VPC 地址:8088> \
    -db <数据库名称> \
    -rp <保留策略名称> \
    -shard <Shard ID> \
    <备份目录>

• 参数说明

  参数	说明
  -portable	使用 portable 备份格式。
  -host	云 TSDB for InfluxDB 的 VPC 网络地址和备份端口，格式为 ts-xxx:8088。
  -db	需要备份的数据库名称。
  -rp	需要备份的保留策略名称。
  -shard	需要备份的 Shard ID，可通过 SHOW SHARDS 查看。
  <备份目录>	备份文件保存目录，例如 /root/tmp/influx_backup。

• 示例

  influxd backup -portable \
    -host ts-xxx.influxdata.tsdb.aliyuncs.com:8088 \
    -db example_db \
    -rp example_rp \
    -shard 123 \
    /root/tmp/influx_backup

  说明

  示例中的 ts-xxx.influxdata.tsdb.aliyuncs.com:8088、example_db、example_rp、123 和 /root/tmp/influx_backup 需要按实际迁移范围替换。

恢复 restore

参考官网文档，将备份后的数据恢复至已存在的数据库。

1. 在自建 InfluxDB 所在的 ECS 上执行恢复命令，将数据恢复至临时数据库。

   • 使用方式

     influxd restore -portable \
       -db <备份的数据库名称> \
       -rp <备份的保留策略名称> \
       -shard <Shard ID> \
       -newdb <临时数据库名称> \
       <备份目录>
     

   • 参数说明

     参数	说明
     -portable	读取 portable 备份格式。
     -db	备份的数据库名称。
     -rp	备份的保留策略名称。
     -shard	备份的 Shard ID。
     -newdb	恢复的临时数据库名称。
     <备份目录>	数据备份所在的目录，例如 /root/tmp/influx_backup。

   • 示例

     influxd restore -portable \
       -db example_db \
       -rp example_rp \
       -shard 123 \
       -newdb example_tmp_db \
       /root/tmp/influx_backup

     示例中的 example_db、example_rp、123、example_tmp_db 和 /root/tmp/influx_backup 需要按实际备份内容替换。

2. 使用 InfluxQL 从临时数据库中查询数据，并写入目标数据库。

   如果数据量较大，SELECT INTO 可能因查询超时导致数据不完整。执行前确认以下事项：

   • 如果启用了查询超时（即设置了 INFLUXDB_COORDINATOR_QUERY_TIMEOUT），将其调整为较大的值。InfluxDB 默认不设置查询超时。

   • 对于数据量较大的场景，建议按时间范围分批执行 SELECT INTO，避免单次查询超时。

     SELECT *
     INTO "example_db"."example_rp".:MEASUREMENT
     FROM "example_tmp_db"."example_rp"/.*/
     GROUP BY *

   /.*/ 为 InfluxQL 正则语法，表示匹配所有 measurement。

3. 验证数据完整性。分别查询临时数据库和目标数据库的数据量，确认数据一致后再执行下一步。

   SELECT COUNT(*) FROM "example_tmp_db"."example_rp"/.*/
   SELECT COUNT(*) FROM "example_db"."example_rp"/.*/

4. 删除临时数据库。

   DROP DATABASE "example_tmp_db";