Elasticsearch:同一リージョンでの Elasticsearch データのレプリケーション

ステップ 1: CEN を使用した同一リージョン内 VPC の接続

Cloud Enterprise Network (CEN) を使用して、リーダー クラスターの VPC とフォロワー クラスターの 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 コンソールにログインします。パブリックエンドポイントを使用する別の手順については、「パブリックエンドポイントを使用して v2/v3 クラスターの Kibana コンソールにログインする」をご参照ください。

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

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

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

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

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

      パラメーター	説明
      名前	リーダー クラスターのインスタンス ID を入力します。
      プロキシモード	プロキシモードを有効にします。
      プロキシアドレス	ステップ 4 で取得した PrivateLink ドメイン名を <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

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