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. [全ポート]機能を有効にし、リスナーポート範囲を [9200-9300] に設定します。

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

ステップ 4: PrivateLink の設定

PrivateLink を使用して、フォロワー クラスターの管理 VPC をリーダー クラスターのネットワークに接続します。

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

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

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

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

      パラメーター	説明
      [サービスリソースタイプ]	[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. [リモートクラスターの追加] をクリックし、次のパラメーターを設定します：

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

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

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

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

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

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

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

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

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

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

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

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

自動フォローパターンを作成する前にリーダー クラスターにすでにインデックスが存在する場合、それらのインデックスは自動的にレプリケートされません。フォロワー クラスターの Kibana コンソールで [スタック管理] > [クロス クラスター レプリケーション] > [フォロワーインデックス] に移動して、手動でフォロワーインデックスを作成する必要があります。

フォロワーインデックスを作成した後、フォロワー クラスターの 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

   返されたドキュメントが書き込んだ内容と一致する場合、新しいデータはリアルタイムで同期されています。