Elasticsearch:リージョン間 Elasticsearch データレプリケーション

ステップ 1：CEN でリージョン間 VPC を接続

Cloud Enterprise Network (CEN) を使用して、リーダー クラスターとフォロワー クラスターの VPC 間にリージョン間接続を確立します。詳細な手順については、「異なるリージョンの VPC を接続」をご参照ください。

ステップ 2：リーダー クラスターのプライベート IP の取得

1. Alibaba Cloud Elasticsearch コンソールにログインします。

2. リーダー クラスターの 基本情報 ページで、内部エンドポイント フィールドを探してプライベート ドメイン名をコピーします。

3. 同じ VPC 内の ECS インスタンスから、以下のコマンドを実行してリーダー クラスターのプライベート IP アドレスを解決します。

   ping <リーダー クラスターのプライベートドメイン名>

   解決された IP アドレスを記録し、後で使用します。

ステップ 3：NLB とサーバーグループの作成

フォロワー クラスターの VPC 内に NLB インスタンスを作成し、リーダー クラスターにトラフィックを転送します。

1. Network Load Balancer (NLB) コンソールにログインします。

2. サーバーグループを作成します。

   1. 左側のナビゲーションペインで、ServerGroup をクリックします。

   2. サーバーグループの作成 をクリックし、以下のパラメーターを設定します：

      パラメータ	説明
      [サーバーグループのタイプ]	IPタイプ を選択します。
      [転送ポート]	フルポート転送 を有効にします。
      [ヘルスチェック]	ポートを 9300 に設定します。

   3. 作成したサーバーグループで、バックエンドサーバーの追加 をクリックします。 ステップ 2 で取得したリーダークラスターのプライベート IP アドレスを追加し、ポートはデフォルトのままにします。

3. NLB インスタンスとリスナーを作成します。

   NLB 購入ページでは、全ポート機能を持つリスナーの作成はサポートされていません。そのため、まずリスナーなしで NLB インスタンスを作成します。次に、インスタンスの詳細ページでリスナーを作成し、全ポート機能を有効にします。

   すでに NLB インスタンスをお持ちの場合は、直接リスナーを作成できます。お持ちでない場合は、まず NLB インスタンスを作成する必要があります。

   1. 左側のナビゲーションペインで、インスタンス をクリックし、NLB インスタンスを選択または作成します。

   2. インスタンス詳細ページに移動し、Listener タブをクリックし、次に リスナーの作成 をクリックします。

   3. [Full-port] 機能を有効にし、リスナーポート範囲を [9200-9300] に設定します。

   4. ServerGroup には、IPタイプ と前の手順で作成したサーバーグループを選択します。

ステップ 4：PrivateLink の構成

PrivateLink を使用して、フォロワー クラスターのマネージド VPC からリーダー クラスターへのネットワーク接続を確立します。

1. [PrivateLink コンソール]にログインします。

2. エンドポイントサービスを作成します。

   1. 左側のナビゲーションペインで、エンドポイントサービス をクリックします。

   2. エンドポイントサービスの作成 をクリックして、次のパラメーターを設定します。

      パラメータ	説明
      [Service Resource Type]	[NLB] を選択します。
      [サービスリソース]	ステップ 3 で作成または使用した NLB インスタンスを選択します。
      [Zone]	NLB インスタンスが配置されているアベイラビリティーゾーンを選択します。
      [エンドポイント接続を自動で許可]	はい を選択します。

3. フォロワー クラスターにプライベート接続を追加します。

   1. Alibaba Cloud Elasticsearch コンソールにログオンし、フォロワークラスターのインスタンス詳細ページに移動します。

   2. 左側のナビゲーションペインで、設定と管理 > セキュリティ設定 を選択します。

   3. クラスターネットワーク設定 セクションで、プライベート接続の設定をクリックします。

   4. プライベート接続の追加 をクリックし、前のステップで作成したエンドポイントサービスを選択します。

   5. 接続ステータスが 接続済み に変わるまでお待ちください。

4. PrivateLink ドメイン名を取得します。

   接続が確立されたら、PrivateLink コンソールに戻ります。 エンドポイントサービスの エンドポイントの接続ステータス タブで、自動的に作成されたエンドポイント接続を表示します。 これは、リモートクラスターを設定するために使用する PrivateLink ドメイン名です。

ステップ 5：クロスクラスターレプリケーション (CCR) を設定

1. フォロワー クラスターの Kibana にログインします。詳細な手順については、「インターネット経由で Kibana コンソールにログイン (v2/v3 デプロイアーキテクチャ)」をご参照ください。

   フォロワー クラスターのインスタンス詳細ページで、左側のナビゲーションペインにあるデータ可視化をクリックし、次に[Kibana へ移動]をクリックします。

2. リモートクラスターを追加します。

   1. Kibana の左側のナビゲーションペインで、[スタック管理] をクリックします。

   2. [データ] セクションで、[リモートクラスター] をクリックします。

   3. [リモートクラスターを追加] をクリックして、次のパラメーターを設定します。

      パラメータ	説明
      [name]	リーダー クラスターのインスタンス ID を入力します。
      [プロキシモード]	プロキシモードを有効にします。
      [プロキシアドレス]	フォロワークラスターのプライベート接続を設定したときに取得した PrivateLink エンドポイントドメイン名を、<domain-name>:9300 の形式で入力します。ドメイン名は、フォロワークラスターインスタンスの [セキュリティ] ページの [プライベート接続の構成] の下に表示されます。

   4. 保存 をクリックし、接続ステータスが [接続済み] であることを確認します。

3. CCR レプリケーションモードを設定します。

   CCR は 2 つのモードをサポートしています。

   モード	説明
   フォロワーインデックス	指定された単一のインデックスをレプリケートします。
   自動フォローパターン	指定された名前パターンに一致するインデックスを自動的にレプリケートします。このモードは一括同期に適しています。 自動フォローパターンを作成した後、リーダー クラスターで作成された新しいインデックスは自動的にフォロワー クラスターに同期されます。既存のインデックスは自動的には同期されません。既存のインデックスを同期するには、フォロワー クラスターでフォロワーインデックスを手動で作成する必要があります。

   次の例では、自動フォローパターンを使用します。

   1. [スタック管理] で、[クラスター間レプリケーション] をクリックします。

   2. [オートフォローパターン] タブを選択し、[オートフォローパターンの作成] をクリックします。

   3. [リモートクラスター] には、前の手順で追加したリモートクラスターを選択します。 [インデックスパターン] には、すべてのインデックスをレプリケートする場合は * を、特定のインデックスのみをレプリケートする場合は logs-* などのインデックス名パターンを入力します。

   4. [作成] をクリックします。

ステップ 6：データ同期の検証

既存のインデックスの同期を検証

自動フォローパターンを作成する前にリーダー クラスターに存在していたインデックスは、自動的にレプリケートされません。フォロワー クラスターの Kibana で、[Stack Management] > [Cross-Cluster Replication] > [Follower indices] に移動して、フォロワーインデックスを手動で作成する必要があります。

フォロワーインデックスを作成した後、フォロワー クラスターの Kibana で以下のコマンドを実行して、データが同期されていることを確認します。

GET /<index_name>/_search

返された結果がリーダー クラスターの結果と一致していれば、既存のデータは同期されています。

新しいデータの同期を検証

1. リーダー クラスターの Kibana で、新しいインデックスを作成し、ドキュメントを書き込みます。

   PUT /test-increment-index
   
   POST /test-increment-index/_doc
   {
       "title": "increment test",
       "content": "This is a test document for CCR incremental sync."
   }

2. フォロワー クラスターの Kibana で、インデックスをクエリします。

   GET /test-increment-index/_search

   返されたドキュメントがソースドキュメントと一致していれば、リアルタイム同期は成功しています。