Hologres：Manajemen kelompok komputasi

Catatan penting

• Hanya Akun Alibaba Cloud atau pengguna Resource Access Management (RAM) dengan izin Superuser untuk instans yang dapat membuat kelompok komputasi.

• Pembuatan kelompok komputasi merupakan operasi asinkron. Setelah Anda mengeksekusi perintah SQL, kelompok komputasi mungkin tidak langsung tersedia. Anda dapat menggunakan fungsi hg_get_warehouse_status untuk memeriksa status operasi pembuatan.

Prosedur

Catatan penting

• Hanya Akun Alibaba Cloud atau pengguna RAM dengan izin Superuser untuk instans yang dapat menghapus kelompok komputasi.

• Anda tidak dapat menghapus kelompok komputasi default suatu instans.

• Anda tidak dapat menghapus kelompok komputasi primary dari kelompok tabel menggunakan perintah SQL.

• Penghapusan kelompok komputasi merupakan operasi asinkron. Setelah Anda mengeksekusi perintah SQL, kelompok komputasi mungkin tidak langsung terhapus. Anda dapat menggunakan fungsi hg_get_warehouse_status untuk memeriksa status operasi penghapusan.

Prosedur

Izin

• Pada versi sebelum V3.0.28, hanya Akun Alibaba Cloud atau pengguna RAM yang dapat mengubah ukuran kelompok komputasi. Mulai V3.0.28, peran RAM (akun STS) juga dapat melakukan operasi ini.

• Untuk mengubah ukuran kelompok komputasi, Anda memerlukan izin berikut:

  • Izin peran RAM: AliyunHologresWarehouseFullAccess atau AliyunHologresFullAccess.

  • Izin Superuser dalam instans.

Untuk informasi selengkapnya tentang skalabilitas elastis untuk kelompok komputasi, lihat Ikhtisar elastisitas resource.

Skalabilitas vertikal

-- Increase compute group resources
CALL hg_alter_warehouse ('read_warehouse_1',64);

-- Wait for scaling to complete
SELECT wait_until_warehouse_running ('read_warehouse_1');

-- Rebalance
SELECT hg_rebalance_warehouse ('read_warehouse_1');

-- Wait for rebalance to complete
SELECT hg_wait_until_rebalance_warehouse_done ('read_warehouse_1');

Penurunan skala vertikal

Perluasan kapasitas horizontal (tambah kluster)

Skala-masuk horizontal (hapus kluster)

Lihat kelompok komputasi

• Sintaks

  • Tabel sistem hologres.hg_warehouses menyimpan informasi tentang semua kelompok komputasi dalam instans saat ini. Anda dapat mengeksekusi pernyataan SQL berikut untuk melihat semua kelompok komputasi:

    SELECT * FROM hologres.hg_warehouses;

  • Anda dapat mengeksekusi pernyataan SQL berikut untuk melihat kelompok komputasi saat ini. Perintah ini mengembalikan nama kelompok komputasi saat ini.

    SELECT current_warehouse();

• Parameter

  Tabel sistem hologres.hg_warehouses berisi bidang-bidang berikut:

  Field	Data type	Description	Example
  warehouse_id	INTEGER	ID unik kelompok komputasi.	1
  warehouse_name	TEXT	Nama kelompok komputasi.	init_warehouse
  cpu	INTEGER	Resource CPU kelompok komputasi (dalam core).	32
  mem	INTEGER	Memori kelompok komputasi (dalam GB).	128
  cluster_min_count	INTEGER	Jumlah minimum shard untuk kelompok komputasi.	1
  cluster_max_count	INTEGER	Jumlah maksimum shard untuk kelompok komputasi.	1
  target_status	INTEGER	Status target kelompok komputasi. Karena perubahan status bersifat asinkron—misalnya, setelah menjalankan perintah SQL untuk membuat kelompok komputasi, sistem langsung mengembalikan respons meskipun pembuatan masih berlangsung—bidang ini mencatat status akhir yang dimaksudkan. Nilai: 1: Berjalan. 2: Dihentikan secara manual.	1
  status	INTEGER	Status saat ini dari kelompok komputasi. Nilai: 0: Menginisialisasi. 1: Berjalan. 2: Dihentikan secara manual. 3: Gagal. Jika statusnya gagal, bidang status_detail menunjukkan alasannya. 4: Memproses.	1
  status_detail	TEXT	Detail status kelompok komputasi.	None
  is_default	BOOLEAN	Menunjukkan apakah ini kelompok komputasi default. Nilai: t: Kelompok komputasi default. f: Bukan kelompok komputasi default.	t
  config	TEXT	Konfigurasi kelompok komputasi.	None
  comment	TEXT	Keterangan untuk kelompok komputasi.	None

Hentikan kelompok komputasi

Lanjutkan kelompok komputasi

Mulai ulang kelompok komputasi

Dapatkan status kelompok komputasi

• Sintaks

  • Anda dapat mengeksekusi pernyataan SQL berikut untuk mengambil status saat ini dari kelompok komputasi:

    select hg_get_warehouse_status('<warehouse_name>');

  • Karena operasi seperti membuat atau mengubah ukuran kelompok komputasi bersifat asinkron, Anda mungkin perlu menunggu perubahan status sebelum melanjutkan. Anda dapat menggunakan fungsi wait_until_warehouse_running untuk menunggu hingga kelompok komputasi yang ditentukan mencapai status `Running`. Fungsi ini hanya mengembalikan nilai setelah kelompok komputasi berjalan. Perintahnya sebagai berikut:

    select wait_until_warehouse_running('<warehouse_name>',<timeout_seconds>);

• Parameter

  Parameter	Type	Description
  warehouse_name	TEXT	Nama kelompok komputasi yang statusnya ingin Anda dapatkan.
  timeout_seconds	INTEGER	Timeout dalam detik. Opsional.

• Contoh penggunaan

  Pernyataan SQL berikut memberikan contoh cara meningkatkan skala kelompok komputasi sebelum mengimpor data dari tabel org_data ke tabel res_data, lalu menurunkan skala kelompok komputasi kembali:

  -- Scale warehouse_1 up to 64 CU
  CALL hg_alter_warehouse ('warehouse_1',64);
  
  -- Wait for scaling to complete
  SELECT wait_until_warehouse_running('warehouse_1');
  
  -- Insert data
  INSERT INTO res_data SELECT * FROM org_data；
  
  -- Scale warehouse_1 back to 32 CU
  CALL hg_alter_warehouse ('warehouse_1',32);

Ubah nama kelompok komputasi

Prosedur

Redistribusi shard dalam kelompok komputasi

Selama operasi normal, node pekerja dalam kelompok komputasi Hologres memuat metadata shard secara merata. Namun, dalam beberapa skenario—seperti saat pemulihan cepat atau penskalaan—shard dapat terdistribusi tidak merata di antara node pekerja. Dalam kasus tersebut, Anda dapat memicu operasi rebalance untuk mendistribusikan ulang shard secara merata.

• Izin

  Anda memerlukan izin Superuser untuk instans agar dapat memicu operasi rebalance.

• Catatan penting

  • Mulai dari Hologres V2.1, jika kelompok komputasi memiliki node pekerja kosong yang tidak memuat shard apa pun, sistem secara otomatis memicu operasi rebalance.

  • Mulai dari Hologres V2.2, sistem secara otomatis mencoba ulang kueri SELECT selama operasi rebalance. Hal ini memungkinkan kueri berhasil diselesaikan setelah penundaan singkat tanpa mengembalikan error seperti ERROR: fail to execute query internal error: Get rundown is not allowed in recovering state.

• Sintaks

  SELECT hg_rebalance_warehouse ('<warehouse_name>');

• Parameter

  Parameter	Type	Description
  warehouse_name	TEXT	Nama compute group yang akan diseimbangkan ulang.

• Nilai kembali

  Setelah Anda memicu operasi rebalance, nilai-nilai berikut dapat dikembalikan:

  • `true`: Operasi rebalance berhasil dipicu. Sistem memulai proses rebalancing.

  • `false`: Operasi rebalance tidak diperlukan.

  • `Error`: Operasi rebalance gagal. Misalnya, jika pod mengalami kerusakan, operasi rebalance gagal.

  Catatan

  • Selama operasi rebalance, sistem mengevaluasi apakah redistribusi diperlukan untuk mencapai keadaan seimbang. Dalam keadaan seimbang, jumlah shard yang dimuat oleh setiap pekerja berbeda tidak lebih dari satu. Contoh:

    • Jika terdapat 2 pekerja dan 2 shard, setiap pekerja dialokasikan 1 shard.

    • Jika terdapat 2 pekerja dan 3 shard, satu pekerja dialokasikan 1 shard dan pekerja lainnya dialokasikan 2 shard.

  • Operasi rebalance biasanya memerlukan waktu 2 hingga 3 menit untuk diselesaikan. Durasi tergantung pada jumlah kelompok tabel dalam kelompok komputasi—semakin banyak kelompok tabel, semakin lama operasi berlangsung. Selama operasi rebalance, operasi tulis terganggu selama sekitar 15 detik.

  • Karena operasi rebalance bersifat asinkron, Anda dapat menggunakan pernyataan SQL berikut untuk memeriksa progresnya:

    SELECT hg_get_rebalance_warehouse_status('<warehouse_name>');

    Nilai kembali DOING menunjukkan bahwa operasi rebalance sedang berlangsung. Nilai kembali DONE menunjukkan bahwa operasi rebalance telah selesai.

Atur durasi timeout kelompok komputasi

Anda dapat mengatur parameter statement_timeout untuk mengonfigurasi durasi timeout pada tingkat sesi atau tingkat database. Untuk informasi selengkapnya, lihat Parameter GUC.

Untuk kelompok komputasi, Anda dapat mengeksekusi perintah berikut untuk mengatur durasi timeout. Konfigurasi ini memiliki prioritas lebih rendah dibandingkan pengaturan tingkat sesi atau tingkat database. Oleh karena itu, Anda harus terlebih dahulu membatalkan pengaturan tingkat database apa pun.

-- Cancel database-level setting
ALTER DATABASE <db_name> RESET statement_timeout;

-- Set compute group timeout to 600 seconds
CALL hg_alter_warehouse ('<warehouse_name>', <cu>, '{"configs":{"gucs":{"statement_timeout":"600000"}}}');