Hologres:リフレッシュタスクの管理

hologres.hg_dynamic_table_refresh_activity の使用

システムテーブル hologres.hg_dynamic_table_refresh_activity は、フルリフレッシュとインクリメンタルリフレッシュを含む実行中のリフレッシュタスクとそのリソース消費量を表示します。フィールドの説明については、「hologres.hg_dynamic_table_refresh_activity」をご参照ください。

このシステムテーブルは、Hologres V3.0 および V4.0.8 以降でのみサポートされています。

-- 現在実行中のリフレッシュタスクを表示
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 ステートメントが表示されます。

• インクリメンタルリフレッシュ： Refresh タスクが表示されます。

hologres.hg_dynamic_table_refresh_log の使用

3.1 構文で作成された動的テーブルの場合、hologres.hg_dynamic_table_refresh_log はリフレッシュタスクログのテーブルごとのビューを提供します。次の例では、特定のテーブルで現在実行中のすべてのリフレッシュタスクをクエリします。

-- 特定のテーブルで実行中のリフレッシュタスクを表示 (3.1 構文)
SELECT query_job_id, status
FROM hologres.hg_dynamic_table_refresh_log('<dynamic_table_name>')
WHERE status = 'RUNNING';

このビューによって返される query_job_id は、実行中のリフレッシュタスクをキャンセルする際にも使用されます。詳細については、「新しい 3.1 構文で作成された動的テーブル」をご参照ください。

監視メトリクスの使用

QPS、RPS (1 秒あたりのレコード数)、レイテンシーなどのメトリクスを確認して、実行ステータスを検証してください。Command Type が refresh の場合、動的テーブルのリフレッシュタスクを示します。詳細については、「監視メトリクス」をご参照ください。

リフレッシュタスクがサーバーレスコンピューティングリソースで実行される場合は、サーバーレスコンピューティングのメトリクスでそのステータスを確認することもできます。

hologres.hg_dynamic_table_refresh_history の使用

システムテーブル hologres.hg_dynamic_table_refresh_history は、過去 1 か月間のすべてのリフレッシュタスク (フルリフレッシュ、インクリメンタルリフレッシュ、手動リフレッシュ) の履歴を記録します。フィールドの説明については、「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 日間のインスタンス内のすべてのリフレッシュタスクの表示

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 日間の特定のテーブルのリフレッシュタスクの表示

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 = '<schema_name>'
  AND dynamic_table_name = '<dynamic_table>'
  AND refresh_start >= CURRENT_DATE - INTERVAL '1 day';

レガシーの 3.0 構文で作成されたフルリフレッシュの動的テーブルの場合、hologres.hg_dynamic_table_refresh_history は成功または失敗のステータスを正確に反映しないことがあります。失敗したリフレッシュが Success として表示される場合があります。これらのテーブルの実際のリフレッシュ履歴を取得するには、次の手順を実行してください：1. hologres.hg_dynamic_table_properties から cron_job_name を取得します。2. その名前を使用して cron ジョブの実行レコードをクエリしてください。

-- ステップ 1：cron_job_name を取得
SELECT property_value AS cron_job_name
FROM hologres.hg_dynamic_table_properties
WHERE dynamic_table_name = '<dt_name>'
  AND property_key = 'cron_job_name';

-- ステップ 2：cron ジョブの実行レコードをクエリ
SELECT *
FROM hologres.hg_user_cron_tasks
WHERE jobname = '<cron_job_name>'
ORDER BY start_time DESC;

スロークエリログの使用

リフレッシュタスクは、Command Type が refresh に設定されたスロークエリログにも表示されます。詳細については、「スロークエリログの取得と分析」をご参照ください。

実行中のリフレッシュタスクのキャンセル

hologres.hg_dynamic_table_refresh_log から実行中のタスクの query_job_id をクエリし、hologres.hg_internal_cancel_query_job を使用してキャンセルします。

-- ステップ 1：query_job_id を取得
SELECT query_job_id
FROM hologres.hg_dynamic_table_refresh_log('<dt_name>')
WHERE status = 'RUNNING';

-- ステップ 2：タスクをキャンセル
SELECT hologres.hg_internal_cancel_query_job('<query_job_id>');

スーパーユーザーのみが hologres.hg_internal_cancel_query_job を使用してリフレッシュタスクをキャンセルできます。

テーブルの自動リフレッシュの一時停止

テーブルレベルで後続のすべてのリフレッシュタスクを停止するには、自動リフレッシュを無効にします。

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

実行中のリフレッシュタスクのキャンセル

リフレッシュタスクの実行時間が長すぎる、またはスタックしているように見える場合は、pg_cancel_backend を使用してキャンセルします。

-- プロセス ID (pid) でリフレッシュタスクをキャンセル
SELECT pg_cancel_backend(<pid>);

pid は hologres.hg_dynamic_table_refresh_activity または hg_stat_activity から取得します。詳細については、「リフレッシュタスクの表示」をご参照ください。

リフレッシュタスクをバッチでキャンセルするには、通常のクエリと同じ方法を使用します。詳細については、「クエリの終了」をご参照ください。

テーブルの自動リフレッシュの一時停止

テーブルレベルで後続のすべてのリフレッシュタスクを停止するには、次のようにします。

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