設置單條SQL的Serverless Computing資源上限

• 您可以執行如下代碼，設置每條SQL被分配的Serverless Computing資源上限。

  -- 配置單個Serverless Computing分配的最大CU，默認為512。
  SET hg_experimental_serverless_computing_max_cores = 512;
  
  -- 重置配置
  reset hg_experimental_serverless_computing_max_cores;

• 使用示例

  -- 使用Serverless Computing資源執行SQL
  SET hg_computing_resource = 'serverless';
  
  -- 設置單條SQL最多使用32CU執行
  SET hg_experimental_serverless_computing_max_cores = 32;
  
  -- 執行SQL
  INSERT INTO sink_tbl SELECT * FROM source_tbl;
  
  -- 重置配置
  reset hg_computing_resource;
  reset hg_experimental_serverless_computing_max_cores;

設置單條SQL的Serverless Computing資源分配

針對hg_experimental_serverless_computing_required_cores參數，系統會根據SQL的復雜程度自動估算需要的資源量。系統自動估算出的資源量可以有效平衡Serverless資源利用和SQL執行時長。若需某條SQL能夠分配到更多的Serverless Computing資源，您可通過設置hg_experimental_serverless_computing_required_cores參數進行Serverless Computing資源分配。

• 您可以執行如下代碼，設置單個SQL語句在執行時所分配的Serverless Computing資源。

  -- 默認為0，表示該Serverless Computing的計算資源由系統自動估算
  SET hg_experimental_serverless_computing_required_cores = XX;
  
  -- 重置配置
  reset hg_experimental_serverless_computing_required_cores;

• 使用示例

  --使用Serverless Computing資源執行SQL
  SET hg_computing_resource = 'serverless';
  
  --Serverless Computing的計算資源不由系統估算，申請96CU的計算資源
  SET hg_experimental_serverless_computing_required_cores = 96;
  
  -- 執行SQL
  INSERT INTO sink_tbl SELECT * FROM source_tbl;
  
  -- 重置配置
  reset hg_computing_resource;
  reset hg_experimental_serverless_computing_required_cores;

設置單條SQL的Serverless Computing資源的優先級

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

  -- 優先級范圍為 [1, 5], 數值越大，優先級越高，越優先分配資源（和分配資源數量無關）
  -- 默認優先級為3.
  SET hg_experimental_serverless_computing_query_priority to 5;
  -- 重置配置
  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;

設置用戶/角色的全部SQL默認通過Serverless Computing執行

您可以執行如下代碼，針對某一用戶/角色，使其發起的全部SQL均默認使用Serverless Computing資源執行。

--針對某用戶在某DB下，默認使用Serverless Computing資源執行SQL
ALTER USER <user_name> IN DATABASE <db_name> SET hg_computing_resource = 'serverless';

設置查詢隊列Query Queue的全部SQL通過Serverless Computing執行

您可以執行如下代碼，以針對某一查詢隊列，使其所有SQL語句均使用Serverless Computing資源執行。有關查詢隊列的配置方法，詳情請參見Query Queue（Beta）。

• 通用型實例

  -- 設置目標Queue中的查詢全部通過Serverless資源運行
  CALL hg_set_query_queue_property('<query_queue_name>', 'computing_resource', 'serverless');
  
  -- （可選）設置目標Queue中的查詢使用Serverless資源時的優先級，支持1-5，默認為3
  CALL hg_set_query_queue_property('<query_queue_name>', 'query_priority_when_using_serverless_computing', '<priority>');

• 計算組型實例

  -- 設置目標Queue中的查詢全部通過Serverless資源運行
  CALL hg_set_query_queue_property('<warehouse_name>', '<query_queue_name>', 'computing_resource', 'serverless');
  
  -- （可選）設置目標Queue中的查詢使用Serverless資源時的優先級，支持1-5，默認為3
  CALL hg_set_query_queue_property('<warehouse_name>', '<query_queue_name>', 'query_priority_when_using_serverless_computing', '<priority>');

查看實例使用Serverless Computing的監控指標

您可通過以下方式查看Serverless Query最長運行時長、Serverless Computing Query排隊數量、Serverless Computing資源Quota使用率的監控指標。如有需要，可進一步配置監控告警，詳情請參見云監控。

1. 登錄Hologres管理控制臺。

2. 在Hologres管理控制臺頂部菜單欄，選擇目標地域。

3. 單擊左側導航欄的實例列表。

4. 在實例列表頁面單擊目標實例名稱，進入實例詳情頁。

   您也可以單擊目標實例操作列的管理，進入實例詳情頁。

5. 在實例詳情頁左側導航欄，單擊監控信息，查看監控指標。

查看Serverless Computing資源中SQL任務的運行狀態

• 查看Serverless Computing資源中正在運行的SQL任務。

  SELECT
      *,
      (running_info::json) ->> 'computing_resource' AS computing_resource,
      (running_info::json) ->> 'current_stage' AS current_stage
  FROM
      hg_stat_activity
  WHERE (running_info::json) ->> 'computing_resource' = 'Serverless'
      AND (running_info::json) -> 'current_stage'->>'stage_name' = 'EXECUTE'

• 查看Serverless Computing資源中排隊的SQL任務。

  SELECT
      *,
      (running_info::json) ->> 'computing_resource' AS computing_resource,
      (running_info::json) ->> 'current_stage' AS current_stage
  FROM
      hg_stat_activity
  WHERE (running_info::json) ->> 'computing_resource' = 'Serverless'
      AND (running_info::json) -> 'current_stage'->>'stage_name' = 'QUEUE'

• 查看Serverless Computing資源中SQL任務的運行狀態。

  SELECT
      *,
      (running_info::json) ->> 'computing_resource' AS computing_resource,
      (running_info::json) ->> 'current_stage' AS current_stage
  FROM
      hg_stat_activity
  WHERE 
      query_id = '<query_id>';

查詢歷史的Serverless Computing任務

• 在慢Query日志中查看在Serverless Computing資源中執行的歷史任務。

  SELECT
      *,
      extended_cost::json ->> 'queue_time_ms' AS queue_time_ms,--Serverless Computing資源中SQL等待排隊時長。
      extended_cost::json ->> 'serverless_allocated_cores' AS serverless_allocated_cores,--Serverless Computing資源分配給當前SQL的CU數。
      extended_cost::json ->> 'serverless_allocated_workers' AS serverless_allocated_workers,--Serverless Computing資源分配給當前SQL的Worker數。
      extended_cost::json ->> 'serverless_resource_used_time_ms' AS serverless_resource_used_time_ms--當前SQL實際占用Serverless Computing資源的時長。
  FROM
      hologres.hg_query_log
  WHERE
      query_extinfo @> ARRAY['serverless_computing'::text];

• 在hologres.hg_serverless_computing_query_log視圖中查看在Serverless Computing資源中執行的歷史任務。

  SELECT
      *
  FROM
      hologres.hg_serverless_computing_query_log;

  說明

  自2.1.18版本開始，為了方便查詢，將慢Query日志中Serverless Computing任務相關內容固化為列，并且新增了hologres hg_serverless_computing_query_log視圖。相對于慢Query日志hologres.hg_serverless_computing_query_log視圖中新增以下字段：

  • queue_time_ms：Serverless Computing資源中SQL等待排隊時長，單位毫秒（ms）。

  • serverless_allocated_cores：Serverless Computing資源實際分配給當前SQL的CU數。

  • serverless_allocated_workers：Serverless Computing資源實際分配給當前SQL的Worker數。

  • serverless_resource_used_time_ms：當前SQL實際占用Serverless Computing資源的時長，單位毫秒（ms）。

  • extended_info字段中新增以下信息：

    • serverless_computing_source：表示SQL來源，表示使用Serverless Computing資源執行的SQL。取值如下：

      • user_submit：自行指定使用Serverless資源執行的SQL，與Query Queue無關。

      • query_queue：指定查詢隊列的SQL全部由Serverless資源執行。

      • query_queue_rerun：通過Query Queue的大查詢控制功能，自動使用Serverless資源重新運行的SQL。

    • query_id_of_triggered_rerun：該字段僅在serverless_computing_source為query_queue_rerun時存在，表示重新運行的SQL對應的原始Query ID。

  針對部分特殊任務，如COPY、CTAS等，在慢Query日志中會產生多條記錄，包括COPY或CTAS本身及其過程中產生的INSERT記錄，其中的INSERT會實際使用Serverless資源執行?？梢酝ㄟ^COPY或CTAS的trans_id字段關聯到INSERT記錄，關聯示例如下。

  SELECT
      query_id,
      query,
      extended_info
  FROM
      hologres.hg_query_log
  WHERE
      extended_info ->> 'source_trx' = '<transaction_id>' -- 通過COPY/CTAS等本身記錄的trans_id字段可以取到transaction id
  ORDER BY
      query_start
  ;

查看當前數據庫運行的SQL占用的Serverless Computing資源

• 查看Serverless Computing資源中正在運行的SQL任務占用的總資源量。

  SELECT
      datname::text as db_name,
      (running_info::json) -> 'current_stage' ->> 'stage_name' AS current_stage,
      SUM(((running_info::json) -> 'current_stage' ->> 'serverless_allocated_cores')::int) AS total_computing_resource,
      count(1) as query_qty
  FROM
      hg_stat_activity
  WHERE (running_info::json) ->> 'computing_resource' = 'Serverless'
  GROUP BY
      1,
      2;

• 返回結果字段說明

  字段	描述
  db_name	數據庫名稱。
  current_stage	當前SQL執行階段。 PARSE：SQL解析。 OPTIMIZE：生成執行計劃。 QUEUE：等待資源。 START：Query開始階段。 EXECUTE：Query執行階段。 FINISH：Query完成。
  total_computing_resourcet	在當前數據庫和SQL執行階段，使用的Serverless Computing資源總量。
  query_qty	SQL數量。