Hologres：使用Serverless Computing執行讀寫任務

Serverless Computing支援的功能範圍

Serverless Computing支援的任務類型如下：

• Hologres V2.1.17 版本起，支援主要的 DML 任務，包括INSERT（不含INSERT OVERWRITE）、INSERT ON CONFLICT(UPSERT)、DELETE和UPDATE。

• Hologres V2.2.14 版本起，支援 DQL 任務。

• Hologres V3.0.1 版本起，支援 DML 中的 COPY 任務。

• Hologres V3.0.9 版本起，支援 DML 中的 CREATE TABLE AS（CTAS）任務。

• Hologres V2.2.42/V3.0.19 版本起，支援 RESHARDING 任務。

• Hologres V3.0.26 版本起，支援 DML 中的 INSERT OVERWRITE 任務（預存程序 hg_insert_overwrite），支援預存程序中的 DML 和 DQL。

• Hologres V3.1.0 版本起，支援 DML 中的原生 INSERT OVERWRITE 文法，支援 REBUILD 任務。

• Hologres V3.1.3 版本起，支援讀寫加密表（含 Hologres 加密內表及 MaxCompute 加密外表）；讀寫 Hologres 加密內表時需開啟 GUC 參數hg_serverless_computing_enable_encrypted_table，詳情請參見資料加密。

• Hologres V3.1.11 版本起，支援 Compaction 任務，詳情請參見使用Serverless Computing執行Compaction任務。

• Hologres V4.0 版本起，支援讀寫 DLF 外表，檔案格式與其他注意事項見基於DLF訪問OSS資料湖加速。

Serverless Computing支援的函數Extension擴充如下：

• ClickHouse

• Flow Analysis

• PostGIS

• RoaringBitmap

• BSI

• Proxima

如下情況不支援Serverless Computing：

• 唯讀從執行個體的查詢（主執行個體、計算群組執行個體可正常使用）。

• 開啟了多行DML事務的查詢，如set hg_experimental_enable_transaction = on。

• 使用Fixed Plan的SQL。

• 跨庫查詢與寫入。

使用Serverless Computing資源執行讀寫任務

Hologres支援您靈活使用Serverless Computing資源。您可按需將單條SQL指向Serverless資源執行，或設定規則使用Serverless資源批量執行SQL。

Hologres支援如下使用方式，在SQL執行前便將其調度到Serverless資源中，按優先順序由高到低生效：

1. SQL層級（Session層級）：設定hg_computing_resource參數為'serverless'，當前串連的讀寫請求將使用Serverless資源執行。

2. 使用者層級：使用者層級設定hg_computing_resource參數為'serverless'，使用Serverless資源執行。

3. 查詢隊列Query Queue層級：設定查詢隊列中的全部任務均使用Serverless資源執行。

4. 自適應Serverless計算：開啟後，系統自動判斷“大任務”，自動使用Serverless資源執行。

5. 不符合上述條件，則使用本執行個體資源執行。

SQL執行中，也支援配置"大查詢"自動使用Serverless資源重跑，以減輕實際生產業務的負載壓力、降低OOM頻率，並提升系統穩定性。

-- 使用Serverless Computing資源執行SQL，預設值為local，表示使用本執行個體資源執行SQL。
SET hg_computing_resource = 'serverless';

-- 提交DML後重設配置，保證非必要的SQL不會使用serverless資源。
RESET hg_computing_resource;

-- 資料準備 --
    -- 建立源表
CREATE TABLE source_tbl ( id int );
    -- 建立目標表
CREATE TABLE sink_tbl ( id int );
    -- 源表寫入範例資料
INSERT INTO source_tbl
SELECT * FROM generate_series(1, 99999999);

-- 使用Serverless Computing資源執行SQL --
    -- Session層級開啟開關
SET hg_computing_resource = 'serverless';
    -- 執行SQL
INSERT INTO sink_tbl SELECT * FROM source_tbl;
    -- 重設配置
RESET hg_computing_resource;

-- 針對某使用者在某DB下，預設使用Serverless Computing資源執行SQL
ALTER USER "<role_name>" IN DATABASE <db_name> SET hg_computing_resource = 'serverless';

-- 取消上述配置
ALTER USER "<role_name>" IN DATABASE <db_name> RESET hg_computing_resource;

設定Serverless Computing任務的優先順序

Hologres支援為進入Serverless Computing的SQL設定優先權。通過設定單條SQL可使用的資源量上限與按優先順序的排隊機制，保障進入Serverless Computing的SQL穩定有序執行。

• 您可以執行如下代碼，設定Serverless Computing資源中SQL執行的優先順序。

  優先順序範圍為 [1, 5]，預設值為3。數值越大，優先順序越高，越優先分配資源（和分配資源數量無關）。

  -- Session層級配置
  SET hg_experimental_serverless_computing_query_priority = 5;
  -- 重設配置
  RESET hg_experimental_serverless_computing_query_priority;
  
  -- User層級配置
  ALTER USER "<role_name>" IN DATABASE <db_name> SET hg_experimental_serverless_computing_query_priority = 5;
  -- 重設配置
  ALTER USER "<role_name>" IN DATABASE <db_name> RESET hg_experimental_serverless_computing_query_priority;

• 使用樣本

  -- 使用Serverless Computing資源執行 SQL.
  SET hg_computing_resource = 'serverless';
  
  -- 設定該SQL的優先順序是5
  SET hg_experimental_serverless_computing_query_priority to 5;
  
  -- 執行SQL
  INSERT INTO sink_tbl SELECT * FROM source_tbl;
   
  -- 重設配置
  RESET hg_computing_resource;
  RESET hg_experimental_serverless_computing_query_priority;

Serverless Computing驗證

您可以執行以下代碼，查看上述SQL執行計畫。

-- 使用Serverless Computing資源執行SQL
SET hg_computing_resource = 'serverless';

-- 執行SQL
EXPLAIN INSERT INTO sink_tbl SELECT * FROM source_tbl;

-- 重設配置
RESET hg_computing_resource;

返回結果如下。返回結果中出現Computing Resource: Serverless，表示該SQL使用Serverless Computing資源執行。

                                        QUERY PLAN                                        
------------------------------------------------------------------------------------------
 Gather  (cost=0.00..5.18 rows=100 width=4)
   ->  Insert  (cost=0.00..5.18 rows=100 width=4)
         ->  Redistribution  (cost=0.00..5.10 rows=100 width=4)
               ->  Local Gather  (cost=0.00..5.10 rows=100 width=4)
                     ->  Decode  (cost=0.00..5.10 rows=100 width=4)
                           ->  Seq Scan on source_tbl  (cost=0.00..5.00 rows=100 width=4)
 Computing Resource: Serverless
 Optimizer: HQO version 2.1.0
(8 rows)

您還可查看 Serverless 資源中正在啟動並執行任務以及歷史任務，詳情請參見Serverless Computing監控與營運。