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. [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 を入力します。
      Proxy mode	プロキシモードを有効にします。
      Proxy address	ステップ 4 で取得した PrivateLink ドメイン名を入力します。形式は <Domain name>:9300 です。

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

3. レプリケーション方法を設定します。

   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

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