Elasticsearch:Replikasi data Elasticsearch dalam wilayah yang sama

Langkah 1: Hubungkan VPC dengan CEN

Gunakan CEN untuk menghubungkan VPC kluster pemimpin dan VPC kluster pengikut. Untuk petunjuk lengkap, lihat Hubungkan VPC dalam wilayah yang sama.

Langkah 2: Dapatkan IP privat kluster pemimpin

1. Masuk ke Konsol Alibaba Cloud Elasticsearch.

2. Di halaman Basic Information kluster pemimpin, temukan bidang Internal Endpoint dan salin nama domain privatnya.

3. Dari instans ECS dalam VPC yang sama, jalankan perintah berikut untuk menyelesaikan alamat IP privat kluster pemimpin:

   ping <leader_cluster_private_domain>

   Catat alamat IP yang diperoleh untuk digunakan pada langkah berikutnya.

Langkah 3: Buat NLB dan kelompok server

Buat instans NLB di VPC kluster pengikut untuk meneruskan lalu lintas ke kluster pemimpin.

1. Masuk ke Konsol NLB.

2. Buat kelompok server.

   1. Di panel navigasi sebelah kiri, klik Server Groups.

   2. Klik Create Server Group dan konfigurasikan parameter berikut:

      Parameter	Description
      Server group type	Pilih IP.
      Forwarding port	Aktifkan All-port Forwarding.
      Health check	Atur Port ke 9300.

   3. Di kelompok server yang baru saja Anda buat, klik Add Backend Servers. Tambahkan alamat IP privat kluster pemimpin dari Langkah 2. Pertahankan port default.

3. Buat instans NLB dan listener.

   Karena halaman pembelian NLB tidak mendukung fitur all-port, buat instans NLB terlebih dahulu tanpa listener. Kemudian, dari halaman detail instans, buat listener dan aktifkan fitur all-port.

   Jika Anda sudah memiliki instans NLB, Anda dapat langsung membuat listener. Jika belum, Anda harus membuat instans NLB terlebih dahulu.

   1. Di panel navigasi sebelah kiri, klik Instances. Pilih atau buat instans NLB.

   2. Buka halaman detail instans, klik tab Listeners, lalu klik Create Listener.

   3. Aktifkan fitur All-port dan atur rentang port listener ke 9200-9300.

   4. Untuk Server Group, pilih IP sebagai tipe dan pilih kelompok server yang Anda buat pada langkah sebelumnya.

Langkah 4: Konfigurasi PrivateLink

Gunakan PrivateLink untuk menghubungkan VPC management kluster pengikut ke kluster pemimpin.

1. Masuk ke Konsol PrivateLink.

2. Buat layanan titik akhir.

   1. Di panel navigasi sebelah kiri, klik Endpoint Services.

   2. Klik Create Endpoint Service dan konfigurasikan parameter berikut:

      Parameter	Description
      Service resource type	Pilih NLB.
      Service resource	Pilih instans NLB yang Anda buat atau gunakan di Langkah 3.
      Zone	Pilih zona ketersediaan tempat instans NLB berada.
      Allow endpoint connection	Pilih Yes.

3. Tambahkan koneksi privat di kluster pengikut.

   1. Masuk ke Konsol Alibaba Cloud Elasticsearch dan buka halaman detail kluster pengikut.

   2. Di panel navigasi sebelah kiri, pilih Configuration and Management > Security Settings.

   3. Di bagian Network Settings, klik Configure Private Connection.

   4. Klik Add Private Connection dan pilih layanan titik akhir yang Anda buat pada langkah sebelumnya.

   5. Tunggu hingga status koneksi menjadi Connected.

4. Dapatkan nama domain PrivateLink.

   Setelah koneksi terbentuk, kembali ke konsol PrivateLink. Pada tab Endpoint Connection Status di layanan titik akhir, periksa koneksi titik akhir yang dibuat secara otomatis. Ini merupakan nama domain privat yang disediakan oleh PrivateLink. Catat nama domain tersebut untuk digunakan saat mengonfigurasi kluster jarak jauh.

Langkah 5: Konfigurasi cross-cluster replication (CCR)

1. Masuk ke Konsol Kibana kluster pengikut. Untuk informasi selengkapnya, lihat Masuk ke Konsol Kibana melalui internet (untuk arsitektur v2/v3).

   Untuk melakukannya, buka halaman detail kluster pengikut, klik Visualization di panel navigasi sebelah kiri, lalu klik Log on to Kibana.

2. Tambahkan remote cluster.

   1. Di menu sebelah kiri Kibana, klik Stack Management.

   2. Di bagian Data, klik Remote Clusters.

   3. Klik Add a remote cluster dan konfigurasikan parameter berikut:

      Parameter	Description
      Name	Masukkan ID instans kluster pemimpin.
      Proxy mode	Aktifkan proxy mode.
      Proxy address	Masukkan nama domain PrivateLink dari Langkah 4. Gunakan format <domain-name>:9300.

   4. Klik Save dan pastikan status koneksi adalah Connected.

3. Konfigurasikan mode replikasi.

   CCR mendukung dua mode:

   Mode	Description
   Follower index	Mereplikasi satu indeks tertentu.
   Auto-follow pattern	Secara otomatis mereplikasi indeks yang sesuai dengan pola nama tertentu. Mode ini cocok untuk sinkronisasi massal. Setelah pola auto-follow dibuat, indeks baru di kluster pemimpin akan secara otomatis disinkronkan ke kluster pengikut. Indeks yang sudah ada tidak disinkronkan secara otomatis. Untuk menyinkronkan indeks yang sudah ada, Anda harus membuat follower index secara manual.

   Contoh ini menggunakan pola auto-follow:

   1. Di Stack Management, klik Cross-Cluster Replication.

   2. Pilih tab Auto-follow patterns dan klik Create an auto-follow pattern.

   3. Untuk Remote cluster, pilih remote cluster yang baru saja Anda tambahkan. Untuk Index patterns, masukkan * untuk mereplikasi semua indeks. Untuk mereplikasi indeks tertentu, Anda dapat memasukkan pola nama, seperti logs-*.

   4. Klik Create.

Langkah 6: Verifikasi sinkronisasi data

Verifikasi sinkronisasi indeks yang sudah ada

Pola auto-follow tidak mereplikasi indeks yang sudah ada. Anda harus membuat follower index secara manual di Konsol Kibana kluster pengikut. Untuk melakukannya, buka Stack Management > Cross-Cluster Replication > Follower Indices.

Setelah Anda membuat follower index secara manual, jalankan perintah berikut di Konsol Kibana kluster pengikut untuk memverifikasi bahwa data telah disinkronkan:

GET /<index-name>/_search

Jika hasil yang dikembalikan konsisten dengan hasil dari kluster pemimpin, data yang sudah ada telah disinkronkan.

Verifikasi sinkronisasi data baru

1. Di Konsol Kibana kluster pemimpin, buat indeks baru dan tulis dokumen ke dalamnya:

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

2. Di Konsol Kibana kluster pengikut, kueri indeks tersebut:

   GET /test-increment-index/_search

   Jika konten dokumen yang dikembalikan sesuai dengan yang Anda tulis, data baru sedang disinkronkan secara real time.