Skip to content

バックアップとリストア

EMQXは分散ストレージスキーマを採用し、システムの高可用性を確保するためにクラスター転送機能も導入しています。

このページでは、システム障害時のデータ損失を防ぐために、運用データおよび設定ファイルのバックアップ方法について説明します。

機能説明

EMQXはバックアップとリカバリを実現するために、データのインポートおよびエクスポート用のCLIコマンドを提供しています。EMQX 4.xのコマンドと似ていますが、エクスポートファイル形式は4.xとは互換性がありません。

  • EMQX 4.xでは、EMQXの設定および組み込みデータベースの必要なすべてのデータを単一のJSONファイルに保存していました。
  • EMQX 5.xでは、エクスポートされたデータはtarファイル形式に圧縮され、大量のユーザーデータをより効率的かつ構造的に扱うことが可能です。

CLIコマンドに加え、EMQX EnterpriseではEMQXダッシュボードにデータバックアップおよびリカバリページを提供しており、ここからデータのインポートおよびエクスポートが可能です。

EMQXがインポートおよびエクスポートに対応しているデータは以下の通りです:

  • EMQXの設定リライトファイルの内容:
    • 認証および認可設定
    • ルール、コネクター、Sink/Source
    • リスナー、ゲートウェイ設定
    • その他のEMQX設定
  • 組み込みデータベース(Mnesia)データ
    • ダッシュボードユーザーおよびREST APIキー
    • クライアント認証情報(組み込みデータベースのパスワード認証、強化認証)
    • PSK認証データ
    • 認可ルール
    • ブラックリストデータ
    • 保持メッセージ
  • EMQXデータディレクトリ(node.data_dir)に保存されているSSL/TLS証明書
  • EMQXデータディレクトリに保存されている認可用acl.confファイル

重要なお知らせ

  • 組み込みデータベースの認証情報およびネームスペースに関連する認可ルールは、個別のネームスペース単位でのエクスポートやインポートはできません。これらのレコードをバックアップまたはリストアするには、グローバルバックアップを使用してください。グローバルバックアップはすべてのネームスペースのレコードをまとめて処理します。
  • バックアップにはEMQXデータディレクトリに保存されているSSL/TLS証明書およびacl.confファイルのみが含まれます。バックアップをインポートする前に、データディレクトリ外に保存されている証明書やacl.confファイルは別途適切な場所にコピーしてください。

バックアップファイルの詳細

  • エクスポートされるファイル名の形式はemqx-export-YYYY-MM-DD-HH-mm-ss.sss.tar.gzで、エクスポート先ディレクトリは<EMQX data directory>/backupです。
  • EMQX v5.7.1以降、保持メッセージのストレージ方式がram(メモリ)に設定されている場合でもバックアップされます。

エクスポート

データは稼働中の任意のクラスターのノードからエクスポート可能です。

インポート

データをインポートするには、EMQXノードが稼働中である必要があり、インポート操作が成功するために以下の条件を満たす必要があります:

  • コアノード+レプリカノードモードが有効な場合、データインポートはコアノードでのみ実行可能です。実際のインポート動作に影響はなく、データはコアノードおよびレプリカノードを含むすべてのクラスターのノードにレプリケートされます。コアノードで操作することで正しいデータインポートが保証されます。
  • データファイルの名前を変更してはいけません。

上記の条件を満たさない場合、インポート処理は中止され、対応するエラーメッセージが表示されます。

データインポート操作中、データはEMQXに存在しない場合は挿入され(insert)、競合がある場合は更新されます(update)。インポート処理は既存のEMQXクラスターのデータを削除しません。

特記事項

稀に既存データとインポートデータが互換性がない場合があります。例えば、EMQXクラスターが組み込みデータベース認証を使用し、ソルトの位置を「サフィックス(suffix)」に設定している一方で、インポートデータは同じ設定を「プレフィックス(prefix)」にしている場合、インポート後に新しい設定が有効となり、以前作成された古いユーザー認証情報は機能しなくなります。

したがって、データをクリアせずにEMQXクラスターにデータをインポートする場合は、特に注意が必要です。

ダッシュボードでのバックアップファイル管理

グローバル管理者はGlobalまたは特定のネームスペースでバックアップファイルを管理できます。ネームスペース管理者は割り当てられたネームスペースのバックアップファイルを管理およびダウンロードできますが、Globalや他のネームスペースのバックアップファイルにはアクセスできません。

TIP

  • ダッシュボードによるバックアップおよびリカバリ機能はEMQX Enterpriseエディションv5.4.0以降で利用可能です。
  • CLIでエクスポートしたバックアップファイルもダッシュボードのバックアップ&リストアページで管理可能です。
  1. ダッシュボードにログインし、System -> Backup & Restoreに移動します。

  2. グローバル管理者の場合、ネームスペースセレクターからGlobalまたは特定のネームスペースを選択します。選択した範囲のバックアップファイル一覧が表示されます。ネームスペースを選択した場合、一覧上部の通知で対象ネームスペースを確認してください。

    ネームスペース管理者はセレクターが表示されません。EMQXはバックアップ操作を割り当てられたネームスペースに制限します。

  3. データをエクスポートするには、Createをクリックします。グローバル管理者はGlobalビューでのみバックアップを作成可能です。特定のネームスペースを選択した場合、Createは無効になります。ネームスペース管理者は割り当てられたネームスペースのバックアップを作成できます。

    バックアップファイル一覧には以下の情報が表示されます:

    • File Name:バックアップファイル名
    • Node Name:バックアップファイルが保存されているノード名であり、そのノードのデータのみを含むわけではありません
    • Created At:バックアップファイルの作成日時
    • File Size:バックアップファイルのサイズ
  4. バックアップファイルを選択範囲に追加するには、Uploadをクリックします。ファイルのアップロードはデータのリストアを行いません。特定のネームスペースの場合、成功メッセージに対象ネームスペースが表示されます。アップロード成功後、ファイルがバックアップファイル一覧に表示されていることを確認してください。

  5. バックアップファイルの管理は、Actions列の以下のボタンで行います:

    • Download:バックアップファイルをローカルデバイスにダウンロード
    • Delete:選択範囲からバックアップファイルを削除
    • Restore:バックアップファイルを選択範囲にインポート。特定のネームスペースを選択している場合、リストア確認ダイアログで対象ネームスペースを確認してから実行してください。リストア成功後、成功メッセージに対象ネームスペースが表示されます。

特定ネームスペースビューでは、アップロード、ダウンロード、削除、リストア操作はそのネームスペースに適用されます。グローバル管理者はこのビューでバックアップファイルの管理およびリストアが可能ですが、バックアップの作成はできません。

REST APIによるバックアップファイル管理

グローバル管理者は以下のエンドポイントに対し、オプションのnamespaceクエリパラメーターを指定できます:

  • GET /api/v5/data/files:バックアップファイル一覧取得
  • POST /api/v5/data/files:バックアップファイルアップロード
  • GET /api/v5/data/files/{filename}:バックアップファイルダウンロード
  • DELETE /api/v5/data/files/{filename}:バックアップファイル削除
  • POST /api/v5/data/import:バックアップファイルインポート

グローバル管理者がnamespaceを省略した場合、操作はGlobalのバックアップファイルに適用されます。ネームスペース管理者の場合、EMQXはこのパラメーターを無視し、割り当てられたネームスペースに操作を適用します。

CLI例

このセクションでは、コマンドラインインターフェースを使ったデータのインポートおよびエクスポート方法を示します。

  1. データをエクスポートします。エクスポートファイルの名前形式はemqx-export-YYYY-MM-DD-HH-mm-ss.sss.tar.gzで、エクスポート先ディレクトリは<EMQX data directory>/backupです:

    bash
    $ ./emqx ctl data export
    Exporting data to "data/backup/emqx-export-2023-06-19-15-14-19.947.tar.gz"...
    Exporting cluster configuration...
    Exporting additional files from EMQX data_dir: "data"...
    Exporting built-in database...
    Exporting emqx_admin database table...
    Exporting emqx_authn_mnesia database table...
    Exporting emqx_enhanced_authn_scram_mnesia database table...
    Exporting emqx_app database table...
    Exporting emqx_acl database table...
    Exporting emqx_psk database table...
    Exporting emqx_banned database table...
    Data has been successfully exported to data/backup/emqx-export-2023-06-19-15-14-19.947.tar.gz.
  2. データをインポートします。インポートするファイル名は絶対パスまたは相対パスで指定可能です。ファイルが<EMQX data directory>/backupディレクトリにある場合は、パスなしのベース名でも指定できます。例:

    bash
    # 絶対パスでファイルをインポート
    $ ./emqx ctl data import /tmp/emqx-export-2023-06-19-15-14-19.947.tar.gz
    Importing data from "/tmp/emqx-export-2023-06-19-15-14-19.947.tar.gz"...
    Importing cluster configuration...
    Importing built-in database...
    Importing emqx_banned database table...
    Importing emqx_psk database table...
    Importing emqx_acl database table...
    Importing emqx_app database table...
    Importing emqx_enhanced_authn_scram_mnesia database table...
    Importing emqx_authn_mnesia database table...
    Importing emqx_admin database table...
    Data has been imported successfully.
    
    # EMQXルートディレクトリからの相対パスでファイルをインポート
    $ ./emqx ctl data import ../../../tmp/emqx-export-2023-06-21-13-28-06.418.tar.gz
    Importing data from "../../../tmp/emqx-export-2023-06-21-13-28-06.418.tar.gz"...
    Importing cluster configuration...
    Importing built-in database...
    Importing emqx_enhanced_authn_scram_mnesia database table...
    Importing emqx_authn_mnesia database table...
    Importing emqx_admin database table...
    Importing emqx_acl database table...
    Importing emqx_banned database table...
    Importing emqx_psk database table...
    Importing emqx_app database table...
    Data has been imported successfully.
    
    # `<EMQX data directory>/backup`ディレクトリからファイルをインポート
    $ cp /tmp/emqx-export-2023-06-21-13-28-06.418.tar.gz /opt/emqx/data/backup/
    $ ./emqx ctl data import emqx-export-2023-06-21-13-28-06.418.tar.gz
    Importing data from "data/backup/emqx-export-2023-06-21-13-28-06.418.tar.gz"...
    Importing cluster configuration...
    Importing built-in database...
    Importing emqx_enhanced_authn_scram_mnesia database table...
    Importing emqx_authn_mnesia database table...
    Importing emqx_admin database table...
    Importing emqx_acl database table...
    Importing emqx_banned database table...
    Importing emqx_psk database table...
    Importing emqx_app database table...
    Data has been imported successfully.