Hologres:Manage refresh tasks

Mediante hologres.hg_dynamic_table_refresh_activity

La tabla del sistema hologres.hg_dynamic_table_refresh_activity muestra las tareas de actualización en ejecución —tanto completas como incrementales— junto con su consumo de recursos. Para ver la descripción de los campos, consulte hologres.hg_dynamic_table_refresh_activity.

Esta tabla del sistema solo es compatible con Hologres V3.0, y V4.0.8 y versiones posteriores.

-- View currently running refresh tasks
SELECT
    pid,
    query_id,
    refresh_mode,
    'RUNNING' AS status,
    refresh_start,
    extract(epoch FROM duration) AS duration,                            -- milliseconds
    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;

Mediante hg_stat_activity

La vista del sistema hg_stat_activity también muestra las tareas de actualización en ejecución. La visualización varía según el modo de actualización:

• Actualización completa: Aparece una sentencia INSERT.

• Actualización incremental: Aparece una tarea de Refresh.

Mediante hologres.hg_dynamic_table_refresh_log

Para las tablas dinámicas creadas con la sintaxis 3.1, hologres.hg_dynamic_table_refresh_log proporciona una vista por tabla de los registros de tareas de actualización. El siguiente ejemplo consulta todas las tareas de actualización que se están ejecutando actualmente para una tabla específica:

-- View running refresh tasks for a specific table (3.1 syntax)
SELECT query_job_id, status
FROM hologres.hg_dynamic_table_refresh_log('<dynamic_table_name>')
WHERE status = 'RUNNING';

El valor query_job_id que devuelve esta vista también se utiliza al cancelar una tarea de actualización en ejecución. Para obtener más información, consulte Tablas dinámicas creadas con la nueva sintaxis 3.1.

Mediante métricas de monitoreo

Compruebe métricas como QPS, RPS (registros por segundo) y latencia para confirmar el estado de ejecución. Un Command Type con valor refresh indica una tarea de actualización de tabla dinámica. Para obtener más información, consulte Monitoring metrics.

Si la tarea de actualización se ejecuta en recursos de Serverless Computing, también puede comprobar su estado en las métricas de Serverless Computing.

Mediante hologres.hg_dynamic_table_refresh_history

La tabla del sistema hologres.hg_dynamic_table_refresh_history registra el historial de todas las tareas de actualización —completas, incrementales y manuales— del último mes. Para ver la descripción de los campos, consulte hologres.hg_dynamic_table_refresh_history.

Los registros se conservan durante un mes. No es posible consultar datos con antigüedad superior a un mes.

Los propietarios de tablas solo pueden ver su propio historial de actualizaciones. Los usuarios con el rol de superusuario pueden ver todos los registros de actualización.

Ejemplo 1: Consulta de tareas de actualización incremental del último día

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;

Ejemplo 2: Consulta de todas las tareas de actualización de la instancia del último día

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';

Ejemplo 3: Consulta de tareas de actualización de una tabla específica del último día

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';

Para las tablas dinámicas de actualización completa creadas con la sintaxis heredada 3.0, hologres.hg_dynamic_table_refresh_history podría no reflejar con precisión el estado de éxito o fallo; una actualización fallida podría aparecer como Success . Para obtener el historial real de actualizaciones de estas tablas: 1. Obtenga el valor de cron_job_name desde hologres.hg_dynamic_table_properties . 2. Consulte los registros de ejecución del trabajo programado (cron) mediante ese nombre.

-- Step 1: Get the 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';

-- Step 2: Query cron job execution records
SELECT *
FROM hologres.hg_user_cron_tasks
WHERE jobname = '<cron_job_name>'
ORDER BY start_time DESC;

Mediante registros de consultas lentas

Las tareas de actualización también aparecen en los registros de consultas lentas con Command Type establecido en refresh. Para obtener más información, consulte Get and analyze slow query logs.

-- Set a 30-minute timeout for all refresh tasks on this table
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 min'
)
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(*) AS count_order
FROM hologres_dataset_tpch_10.lineitem
WHERE l_shipdate <= DATE '1998-12-01' - INTERVAL '120' DAY
GROUP BY l_returnflag, l_linestatus;

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

REFRESH DYNAMIC TABLE <schema_name.table_name> WITH (
    refresh_guc_statement_timeout = '30 min'
);

Cancelación de una tarea de actualización en ejecución

Consulte el query_job_id de la tarea en ejecución desde hologres.hg_dynamic_table_refresh_log y, a continuación, cancélela mediante hologres.hg_internal_cancel_query_job.

-- Step 1: Get the query_job_id
SELECT query_job_id
FROM hologres.hg_dynamic_table_refresh_log('<dt_name>')
WHERE status = 'RUNNING';

-- Step 2: Cancel the task
SELECT hologres.hg_internal_cancel_query_job('<query_job_id>');

Solo un superusuario puede cancelar una tarea de actualización mediante hologres.hg_internal_cancel_query_job .

Pausa de la actualización automática de una tabla

Para detener todas las tareas de actualización subsiguientes a nivel de tabla, deshabilite la actualización automática:

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

Cancelación de una tarea de actualización en ejecución

Si una tarea de actualización tarda demasiado o parece estar atascada, cancélela mediante pg_cancel_backend.

-- Cancel the refresh task by its process ID (pid)
SELECT pg_cancel_backend(<pid>);

Obtenga el pid desde hologres.hg_dynamic_table_refresh_activity o hg_stat_activity. Para obtener más información, consulte View refresh tasks

Para cancelar tareas de actualización en lotes, utilice el mismo método que para las consultas normales. Para obtener más información, consulte Terminate a query .

Pausa de la actualización automática de una tabla

Para detener todas las tareas de actualización subsiguientes a nivel de tabla:

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