Time Series Database:Cloud TSDB for InfluxDB のデータ移行ソリューション

シャードリストの表示

バックアップを実行する前に、次の InfluxQL ステートメントを実行して、すべてのシャードの情報を表示し、移行するシャードを決定します：

SHOW SHARDS

結果から、各シャードのid、database、およびretention_policy フィールドを取得します。これらのフィールドは、後続のバックアップコマンドでパラメーターとして使用されます。バックアップおよび復元操作は、各シャードで個別に実行する必要があります。

バックアップ

セルフホストの InfluxDB をホストする ECS インスタンスでバックアップコマンドを実行し、シャードごとにデータをバックアップします。バックアップごとにデータベース名、保持ポリシー名、シャード ID を指定する必要があります。

• 構文

  influxd backup -portable \
    -host <source instance VPC address:8088> \
    -db <database name> \
    -rp <retention policy name> \
    -shard <shard ID> \
    <backup directory>

• パラメーター

  パラメーター	説明
  -portable	ポータブルバックアップ形式を使用します。
  -host	Cloud TSDB for InfluxDB インスタンスの VPC エンドポイントとバックアップポートは、ts-xxx:8088 形式です。
  -db	バックアップするデータベースの名前。
  -rp	バックアップする保持ポリシーの名前。
  -shard	バックアップするシャードの ID です。SHOW SHARDS を実行してシャード ID を取得します。
  <バックアップディレクトリ>	バックアップファイルを保存するディレクトリです。例: /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 を実際の移行範囲に適した値に置き換えてください。

リストア

公式ドキュメントを参照して、既存のデータベースにデータをリストアしてください。

1. セルフホストの InfluxDB をホストする ECS インスタンスで、リストアコマンドを実行して一時データベースにデータをリストアします。

   • 構文

     influxd restore -portable \
       -db <backed-up database name> \
       -rp <backed-up retention policy name> \
       -shard <shard ID> \
       -newdb <temporary database name> \
       <backup directory>
     

   • パラメーター

     パラメーター	説明
     -portable	ポータブルバックアップ形式を読み取ります。
     -db	バックアップされたデータベースの名前。
     -rp	バックアップされた保持ポリシーの名前。
     -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 をバッチで実行してください。

     -- 'cpu' というメジャーメントのデータをコピーする例
     SELECT *
     INTO "example_db"."example_rp"."cpu"
     FROM "example_tmp_db"."example_rp"."cpu"
     GROUP BY *

   /.*/ は、すべてのメジャーメントに一致する InfluxQL の正規表現構文です。

3. データ整合性を検証します。一時データベースと移行先データベースの両方で、行数をクエリします。次の手順に進む前に、データが一致していることを確認してください。

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

4. 一時データベースを削除します。

   DROP DATABASE "example_tmp_db";