Hologres:Kelola tugas refresh

Menggunakan hologres.hg_dynamic_table_refresh_activity

Tabel sistem hologres.hg_dynamic_table_refresh_activity menampilkan tugas refresh yang sedang berjalan — termasuk refresh penuh dan bertahap — beserta konsumsi sumber dayanya. Untuk deskripsi bidang, lihat hologres.hg_dynamic_table_refresh_activity.

Tabel sistem ini hanya didukung di Hologres V3.0, serta V4.0.8 dan versi setelahnya.

-- Lihat tugas refresh yang sedang berjalan
SELECT
    pid,
    query_id,
    refresh_mode,
    'RUNNING' AS status,
    refresh_start,
    extract(epoch FROM duration) AS duration,                            -- milidetik
    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;

Menggunakan hg_stat_activity

Tampilan sistem hg_stat_activity juga menampilkan tugas refresh yang sedang berjalan. Tampilannya berbeda berdasarkan mode refresh:

• Refresh penuh: Pernyataan INSERT muncul.

• Refresh bertahap: Tugas Refresh muncul.

Menggunakan hologres.hg_dynamic_table_refresh_log

Untuk tabel dinamis yang dibuat dengan sintaksis 3.1, hologres.hg_dynamic_table_refresh_log menyediakan tampilan log tugas refresh per tabel. Contoh berikut mengkueri semua tugas refresh yang sedang berjalan untuk tabel tertentu:

-- Lihat tugas refresh yang sedang berjalan untuk tabel tertentu (sintaksis 3.1)
SELECT query_job_id, status
FROM hologres.hg_dynamic_table_refresh_log('<dynamic_table_name>')
WHERE status = 'RUNNING';

query_job_id yang dikembalikan oleh tampilan ini juga digunakan saat membatalkan tugas refresh yang sedang berjalan. Untuk informasi selengkapnya, lihat Tabel dinamis yang dibuat dengan sintaksis baru 3.1.

Menggunakan metrik pemantauan

Periksa metrik seperti QPS, RPS (records per second), dan latensi untuk mengonfirmasi status eksekusi. Command Type bernilai refresh menunjukkan tugas refresh tabel dinamis. Untuk informasi selengkapnya, lihat Metrik pemantauan.

Jika tugas refresh dijalankan pada sumber daya Serverless Computing, Anda juga dapat memeriksa statusnya di metrik Serverless Computing.

Menggunakan hologres.hg_dynamic_table_refresh_history

Tabel sistem hologres.hg_dynamic_table_refresh_history mencatat riwayat semua tugas refresh — penuh, bertahap, dan manual — selama sebulan terakhir. Untuk deskripsi bidang, lihat hologres.hg_dynamic_table_refresh_history.

Catatan disimpan selama satu bulan. Data yang lebih tua dari satu bulan tidak dapat dikueri.

Hanya pemilik tabel yang dapat melihat riwayat refresh mereka sendiri. Pengguna dengan role superuser dapat melihat semua catatan refresh.

Contoh 1: Lihat tugas refresh bertahap dari hari kemarin

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;

Contoh 2: Lihat semua tugas refresh dalam instans dari hari kemarin

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

Contoh 3: Lihat tugas refresh untuk tabel tertentu dari hari kemarin

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

Untuk tabel dinamis full-refresh yang dibuat dengan sintaksis lama 3.0, hologres.hg_dynamic_table_refresh_history mungkin tidak mencerminkan status keberhasilan atau kegagalan secara akurat — refresh yang gagal mungkin tampak sebagai Success. Untuk mengambil riwayat refresh yang sebenarnya untuk tabel-tabel ini: 1. Dapatkan cron_job_name dari hologres.hg_dynamic_table_properties. 2. Kueri catatan eksekusi cron job menggunakan nama tersebut.

-- Langkah 1: Dapatkan 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';

-- Langkah 2: Kueri catatan eksekusi cron job
SELECT *
FROM hologres.hg_user_cron_tasks
WHERE jobname = '<cron_job_name>'
ORDER BY start_time DESC;

Menggunakan log kueri lambat

Tugas refresh juga muncul di log kueri lambat dengan Command Type bernilai refresh. Untuk informasi selengkapnya, lihat Dapatkan dan analisis log kueri lambat.

Batalkan tugas refresh yang sedang berjalan

Kueri query_job_id dari tugas yang sedang berjalan dari hologres.hg_dynamic_table_refresh_log, lalu batalkan menggunakan hologres.hg_internal_cancel_query_job.

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

-- Langkah 2: Batalkan tugas
SELECT hologres.hg_internal_cancel_query_job('<query_job_id>');

Hanya superuser yang dapat membatalkan tugas refresh menggunakan hologres.hg_internal_cancel_query_job.

Jeda auto-refresh untuk tabel

Untuk menghentikan semua tugas refresh berikutnya di tingkat tabel, nonaktifkan auto-refresh:

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

Batalkan tugas refresh yang sedang berjalan

Jika tugas refresh berlangsung terlalu lama atau tampak macet, batalkan menggunakan pg_cancel_backend.

-- Batalkan tugas refresh berdasarkan ID prosesnya (pid)
SELECT pg_cancel_backend(<pid>);

Dapatkan pid dari hologres.hg_dynamic_table_refresh_activity atau hg_stat_activity. Untuk informasi selengkapnya, lihat Lihat tugas refresh.

Untuk membatalkan tugas refresh secara batch, gunakan metode yang sama seperti untuk kueri biasa. Untuk informasi selengkapnya, lihat Hentikan kueri.

Jeda auto-refresh untuk tabel

Untuk menghentikan semua tugas refresh berikutnya di tingkat tabel:

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