Hologres:Manage refresh tasks

Utilisation de hologres.hg_dynamic_table_refresh_activity

La table système hologres.hg_dynamic_table_refresh_activity affiche les tâches d'actualisation en cours, y compris les actualisations complètes et incrémentielles, ainsi que leur consommation de ressources. Pour la description des champs, consultez hologres.hg_dynamic_table_refresh_activity.

Cette table système est prise en charge uniquement dans Hologres V3,0, et V4.0.8 et versions ultérieures.

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

Utilisation de hg_stat_activity

La vue système hg_stat_activity affiche également les tâches d'actualisation en cours. L'affichage varie selon le mode d'actualisation :

• Actualisation complète : Une instruction INSERT apparaît.

• Actualisation incrémentielle : Une tâche Refresh apparaît.

Utilisation de hologres.hg_dynamic_table_refresh_log

Pour les tables dynamiques créées avec la syntaxe 3,1, hologres.hg_dynamic_table_refresh_log offre une vue par table des journaux de tâches d'actualisation. L'exemple suivant interroge toutes les tâches d'actualisation actuellement en cours pour une table spécifique :

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

L'ID query_job_id renvoyé par cette vue est également utilisé lors de l'annulation d'une tâche d'actualisation en cours. Pour plus d'informations, consultez Tables dynamiques créées avec la nouvelle syntaxe 3,1.

Utilisation des métriques de surveillance

Vérifiez des métriques telles que le QPS, le RPS (enregistrements par seconde) et la latence pour confirmer l'état d'exécution. Un Command Type défini sur refresh indique une tâche d'actualisation de table dynamique. Pour plus d'informations, consultez Métriques de surveillance.

Si la tâche d'actualisation s'exécute sur des ressources Serverless Computing, vous pouvez également vérifier son état dans les métriques Serverless Computing.

Utilisation de hologres.hg_dynamic_table_refresh_history

La table système hologres.hg_dynamic_table_refresh_history enregistre l'historique de toutes les tâches d'actualisation (complètes, incrémentielles et manuelles) pour le mois écoulé. Pour la description des champs, consultez hologres.hg_dynamic_table_refresh_history.

Les enregistrements sont conservés pendant un mois. Les données de plus d'un mois ne peuvent pas être interrogées.

Les propriétaires de table peuvent afficher uniquement leur propre historique d'actualisation. Les utilisateurs disposant du rôle superuser peuvent afficher tous les enregistrements d'actualisation.

Exemple 1 : Afficher les tâches d'actualisation incrémentielles du jour précédent

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;

Exemple 2 : Afficher toutes les tâches d'actualisation de l'instance du jour précédent

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

Exemple 3 : Afficher les tâches d'actualisation d'une table spécifique du jour précédent

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

Pour les tables dynamiques à actualisation complète créées avec l'ancienne syntaxe 3,0, hologres.hg_dynamic_table_refresh_history peut ne pas refléter avec précision l'état de réussite ou d'échec — une actualisation ayant échoué peut apparaître comme Success . Pour récupérer le véritable historique d'actualisation de ces tables : 1. Obtenez le cron_job_name depuis hologres.hg_dynamic_table_properties . 2. Interrogez les enregistrements d'exécution des tâches cron en utilisant ce nom.

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

Utilisation des journaux de requêtes lentes

Les tâches d'actualisation apparaissent également dans les journaux de requêtes lentes avec Command Type défini sur refresh. Pour plus d'informations, consultez Obtenir et analyser les journaux de requêtes lentes.

Annuler une tâche d'actualisation en cours

Interrogez l'identifiant query_job_id de la tâche en cours depuis hologres.hg_dynamic_table_refresh_log, puis annulez-la en utilisant 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>');

Seul un superuser peut annuler une tâche d'actualisation en utilisant hologres.hg_internal_cancel_query_job .

Suspendre l'actualisation automatique pour une table

Pour arrêter toutes les tâches d'actualisation suivantes au niveau de la table, désactivez l'actualisation automatique :

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

Annuler une tâche d'actualisation en cours

Si une tâche d'actualisation prend trop de temps ou semble bloquée, annulez-la en utilisant pg_cancel_backend.

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

Obtenez l'identifiant pid depuis hologres.hg_dynamic_table_refresh_activity ou hg_stat_activity. Pour plus d'informations, consultez Afficher les tâches d'actualisation

Pour annuler des tâches d'actualisation par lots, utilisez la même méthode que pour les requêtes classiques. Pour plus d'informations, consultez Terminer une requête .

Suspendre l'actualisation automatique pour une table

Pour arrêter toutes les tâches d'actualisation suivantes au niveau de la table :

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