AnalyticDB:pg_cron

┌───────────── minute (0 - 59)
│ ┌────────────── hour (0 - 23)
│ │ ┌─────────────── day of month (1 - 31)
│ │ │ ┌──────────────── month (1 - 12)
│ │ │ │ ┌───────────────── day of week (0 - 6, 0 is Sunday)
│ │ │ │ │
* * * * *

Planification de base

SELECT cron.schedule('<schedule>', '<command>');

Exemples :

-- Delete events older than 1 week every Saturday at 3:30 AM GMT
SELECT cron.schedule('30 3 * * 6', $$DELETE FROM events WHERE event_time < now() - interval '1 week'$$);

-- Call the test() function daily at 10:00 AM GMT
SELECT cron.schedule('0 10 * * *', 'select test()');

-- Run a SQL statement every minute
SELECT cron.schedule('* * * * *', 'select 1');

-- Run VACUUM FULL on the 1st and 30th of each month, and every Saturday and Sunday, at 2:30 AM GMT
SELECT cron.schedule('30 2 1,30 * 6,0', 'VACUUM FULL');

Planification d'une tâche avec un nom

Attribuez un nom pour faciliter l'identification et la gestion des tâches ultérieurement.

SELECT cron.schedule('<job_name>', '<schedule>', '<command>');

Exemples :

SELECT cron.schedule('Delete Expired Data', '30 3 * * 6', $$DELETE FROM events WHERE event_time < now() - interval '1 week'$$);
SELECT cron.schedule('Select Per Minute', '* * * * *', 'select 1');
SELECT cron.schedule('Do Vacuum', '0 23 * * *', 'VACUUM FULL');

Planification d'une tâche sur une base de données spécifique

Dans les versions de pg_cron antérieures à la 1.4, les tâches ne pouvaient s'exécuter que dans la base de données où l'extension était installée. L'exécution de tâches dans d'autres bases de données nécessitait de manipuler directement la table cron.job, ce qui était peu pratique et peu sécurisé. À partir de la version 1.4 de pg_cron, vous pouvez spécifier directement une base de données cible et un compte dans cron.schedule().

SELECT cron.schedule('<job_name>', '<schedule>', '<command>', '<database>', '<username>', '<active>');

Exemples :

-- Run VACUUM FULL on the dw database daily at 11:00 PM GMT
SELECT cron.schedule('Do Vacuum', '0 23 * * *', 'VACUUM FULL', 'dw');

-- Run a SQL statement in the dw database every minute as gp1234
SELECT cron.schedule('Select Per Minute', '* * * * *', 'select 1', 'dw', 'gp1234');

-- Call test() in the dw database daily at 10:00 AM GMT as user1
SELECT cron.schedule('DO Function', '0 10 * * *', 'select test()', 'dw', 'user1', true);

SELECT cron.alter_job(<job_id>, '<schedule>', '<command>', '<database>', '<username>', '<active>');

-- Change the schedule for job 3 to daily at 11:00 AM GMT
SELECT cron.alter_job(3, '0 11 * * *');

-- Change the command for job 1 to VACUUM
SELECT cron.alter_job(1, null, 'VACUUM');

-- Change the database account for job 2 to gp1234
SELECT cron.alter_job(2, null, null, null, 'gp1234');

Suppression par nom de tâche

SELECT cron.unschedule('<job_name>');

Exemple :

SELECT cron.unschedule('Do Vacuum');

Suppression par ID de tâche

SELECT cron.unschedule(<job_id>);

Exemple :

SELECT cron.unschedule(21);

Recherchez l'ID de tâche dans la table cron.job.

SELECT * FROM cron.job;

-- View all failed jobs
SELECT * FROM cron.job_run_details WHERE status = 'failed';

-- View execution history for job 1
SELECT * FROM cron.job_run_details WHERE jobid = '1';