Time Series Database：雲 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";