Hologres:Hologres の動的テーブルの更新タスクのメンテナンス

実行中の更新タスクのクエリ

hologres.hg_dynamic_table_refresh_activity システムテーブルの使用

hologres.hg_dynamic_table_refresh_activity システムテーブルから、実行中の全量および増分データリフレッシュタスク、およびそれらのリソース消費量をクエリできます。

-- 実行中の更新タスクをクエリする
SELECT
    pid,
    query_id,
    refresh_mode,
    'RUNNING' as status,
    refresh_start,
    extract(epoch from duration) as duration, -- 秒
    serverless_queue_time_ms::bigint / 1000 AS serverless_queue_time_sec,
    serverless_resource_used_time_ms::bigint / 1000 AS serverless_resource_used_time_sec,
    serverless_allocated_cores
FROM
    hologres.hg_dynamic_table_refresh_activity
WHERE datname = '${database}'
  AND table_write = quote_ident('${schema}') || '.' || quote_ident('${tableName}')
ORDER BY refresh_start DESC
limit 2000;

システムビュー hg_stat_activity の使用

hg_stat_activity システムビューから実行中のリフレッシュタスクをクエリできます。表示される内容は、設定したリフレッシュモードによって異なります。

• 完全データ更新：INSERT ステートメントが表示されます。

• 増分データ更新：更新タスクが表示されます。

メトリクスを使用して更新タスクのステータスを確認する

1 秒あたりのクエリ数（QPS）、1 秒あたりのレコード数（RPS）、レイテンシなどのメトリクスを使用して、更新タスクのステータスを確認できます。 コマンドタイプパラメータの値 refresh は、動的テーブルの更新タスクを示します。 メトリクスの詳細については、Hologres メトリクス をご参照ください。

サーバーレスコンピューティングリソースを使用して動的テーブルの更新タスクを実行する場合は、サーバーレスコンピューティング関連のメトリクスを表示してタスクのステータスを確認することもできます。

履歴更新タスクのクエリ

システムテーブル hologres.hg_dynamic_table_refresh_history の使用

hologres.hg_dynamic_table_refresh_history システムテーブルには、完全データリフレッシュ、増分データリフレッシュ、手動リフレッシュタスクなど、直近 1 か月以内のすべての履歴リフレッシュタスクが記録されます。

• 例 1：過去 1 日間のすべての増分データ更新タスクをクエリする。

  -- 過去 1 日間のすべての増分データ更新タスクをクエリする。
  SELECT
      query_id,
      refresh_mode,
      status,
      refresh_start,
      duration,
      refresh_latency / 1000 AS refresh_latency_second,
      serverless_allocated_cores,
      queue_time_ms::bigint / 1000 AS queue_time_second,
      serverless_resource_used_time_ms::bigint / 1000 AS serverless_resource_used_time_second
  FROM
      hologres.hg_dynamic_table_refresh_history
  WHERE
      refresh_start >= CURRENT_DATE - INTERVAL '1 day'
      AND dynamic_table_name = '<dynamic_table>'
      AND refresh_mode = 'incremental'
  ORDER BY
      refresh_start DESC
  limit 100;
  

• 例 2：過去 1 日間の現在のインスタンス内のすべての更新タスクをクエリする。

  -- 過去 1 日間の現在のインスタンス内のすべての更新タスクをクエリする。
  SELECT 
  query_id,
      refresh_mode,
      status,
      refresh_start,
      duration,
      refresh_latency / 1000 AS refresh_latency_second,
      serverless_allocated_cores,
      queue_time_ms::bigint / 1000 AS queue_time_second,
      serverless_resource_used_time_ms::bigint / 1000 AS serverless_resource_used_time_second
  FROM hologres.hg_dynamic_table_refresh_history where refresh_start >= CURRENT_DATE - INTERVAL '1 day'

• 例 3：過去 1 日間の特定のテーブルの更新タスクをクエリする。

  -- 過去 1 日間の特定のテーブルの更新タスクをクエリする。
  SELECT 
  query_id,
      refresh_mode,
      status,
      refresh_start,
      duration,
      refresh_latency / 1000 AS refresh_latency_second,
       serverless_allocated_cores,
      queue_time_ms::bigint / 1000 AS queue_time_second,
      serverless_resource_used_time_ms::bigint / 1000 AS serverless_resource_used_time_second
  FROM hologres.hg_dynamic_table_refresh_history where schema_name='<scehma_name>' and dynamic_table_name='<dynamic_table>' and  refresh_start >= CURRENT_DATE - INTERVAL '1 day'

低速クエリログの使用

低速クエリログで動的テーブルの更新タスクをクエリできます。 コマンドタイプパラメータの値 refresh は、動的テーブルの更新タスクを示します。 詳細については、低速クエリログのクエリと分析 をご参照ください。

テーブルレベルの設定

動的テーブルを作成するときにタイムアウト期間を設定すると、その設定は、作成されたテーブルのすべてのリフレッシュタスクに適用されます。 次の SQL 文では、パブリックデータセット tpch_10g を例として使用します。 文を実行する前に、tpch_10g パブリックデータセットのデータが Hologres にインポートされていることを確認してください。 詳細については、「パブリックデータセットのインポートタスクを作成する」をご参照ください。

-- テーブルを作成するときに、更新タスクのタイムアウト期間を構成します。
CREATE DYNAMIC TABLE tpch_q1_batch
  WITH (
    refresh_mode='full',
    auto_refresh_enable='true',
    full_auto_refresh_interval='1 hours',
    refresh_guc_statement_timeout='30 mins'-- タイムアウト期間は 30 分です。
       ) 
AS
  SELECT
        l_returnflag,
        l_linestatus,
        SUM(l_quantity) AS sum_qty,
        SUM(l_extendedprice) AS sum_base_price,
        SUM(l_extendedprice * (1 - l_discount)) AS sum_disc_price,
        SUM(l_extendedprice * (1 - l_discount) * (1 + l_tax)) AS sum_charge,
        AVG(l_quantity) AS avg_qty,
        AVG(l_extendedprice) AS avg_price,
        AVG(l_discount) AS avg_disc,
        COUNT(*) asAScount_order
FROM
        hologres_dataset_tpch_10.lineitem
WHERE
        l_shipdate <= DATE '1998-12-01' - INTERVAL '120' DAY
GROUP BY
        l_returnflag,
        l_linestatus;

セッションレベルの設定

タイムアウト期間を手動で構成します。 SQL サンプルコード：

SET statement_timeout = <time>;
refresh DYNAMIC TABLE <dynamic_schema_name.dynamic_table_name>;

詳細については、アクティブなクエリのタイムアウト期間の変更 をご参照ください。

実行中の更新タスクのキャンセル

リフレッシュタスクが長時間実行されているか、スタックしている場合は、pg_cancel_backend 関数を使用してタスクをキャンセルできます。

次のステートメントを実行して、実行中の単一の更新タスクをキャンセルできます。

// pid パラメータは、キャンセルする更新タスクの ID を指定します。
SELECT pg_cancel_backend(<pid>);

pid パラメータは、更新タスクの ID を指定します。 更新タスクをクエリして ID（query_id）を取得できます。 詳細については、このトピックの更新タスクのクエリ セクションをご参照ください。

動的テーブルのすべての更新タスクのキャンセル

動的テーブルに更新タスクが構成されている場合、テーブルレベルで後続のすべての更新タスクをキャンセルできます。

ALTER DYNAMIC TABLE [IF EXISTS ] [<schema>.]<table_name> set (auto_refresh_enable=false);