瀚高数据库安全版4.5.8系列使用pg_cron定时任务

环境

系统平台：Linux x86-64 Red Hat Enterprise Linux 7
版本：4.5.8

文档用途

本文档主要介绍瀚高数据库安全版中如何使用pg_cron插件，适用版本是4.5.8系列，pg_cron版本是1.3。

详细信息

pg_cron是瀚高数据库中基于CRON的一个简单的作业调度程序，可以实现一些定时任务，例如定时执行vacuum、批处理、刷新物化视图等，同时支持跨库执行定时任务。下面介绍其详细的功能和使用。

一、参数介绍

二、安装和配置

1.创建pg_cron之前，postgresql.auto.conf文件中配置如下参数

[root@localhost ~]# vi $PGDATA/postgresql.auto.conf

shared_preload_libraries = '已配置的库文件, pg_cron' # pg_cron依赖的预加载库，必须配置 cron.database_name = 'dbname' # 配置创建pg_cron插件的数据库，例如highgo、testdb cron.use_background_workers = 'on' cron.timezone = 'PRC' cron.max_running_jobs = 5 # 默认5，按需设定

2.系统用户root下重启数据库生效

[root@localhost ~]# pg_ctl restart
3.创建pg_cron插件

创建pg_cron插件需要关闭三权，详细如下：

1）syssso登录数据库关闭三权 highgo=>selectshow_secure_param();--如果hg_sepofpowers是off，表示三权已关闭，只执行第3）步即可highgo=>selectset_secure_param('hg_sepofpowers','off');2）系统用户root下重启数据库[root@localhost~]# pg_ctl restart3）sysdba创建pg_cron插件 cron_db=>createextension pg_cron;4）syssso开启三权 highgo=>selectset_secure_param('hg_sepofpowers','on');5）系统用户root下重启数据库[root@localhost~]# pg_ctl restart6）syssso确认三权已开启 highgo=>selectshow_secure_param();--hg_sepofpowers变成on即可

4.sysdba把cron模式的usage权限赋给普通用户

cron_db=> grant usage on schema cron to 普通用户;
表的属主是普通用户时，对表的一些定时操作需要使用普通用户创建定时任务，因为sysdba用户对表没有读写权限

至此，pg_cron的配置和创建完成。

三、功能介绍

1.创建定时任务

pg_cron支持两种创建定时任务的方式：

1）使用时间间隔的方式创建

selectcron.job_create('<任务名称>','<定时任务>','<时间间隔>','<开始时间>');selectcron.job_create('<定时任务>','<时间间隔>','<开始时间>');selectcron.job_create('<定时任务>','<时间间隔>');

注①：如果任务名称已经创建过，那么会修改已有的任务而不创建新的。需要特别注意如果是想创建新的定时任务，则一定要保证任务名称从未创建过，否则会覆盖已有任务。

注②：创建定时任务时，如果不设定开始时间，默认立刻执行一次，建议设定一个开始时间，以避开业务时间或者其他定时任务。

2）使用cron语法设定定时计划的方式创建

selectcron.schedule('<任务名称>','<定时计划>','<定时任务>');selectcron.schedule('<定时计划>','<定时任务>');

注：如果任务名称已经创建过，那么会修改已有的任务而不创建新的。需要特别注意如果是想创建新的定时任务，则一定要保证任务名称从未创建过，否则会覆盖已有任务。

pg_cron的定时计划schedule的设置规则如下：

其中，pg_cron计划使用标准的CRON语法，*表示每个该时间运行，指定数字则表示仅在这个时间运行，如下所示。

-- ┌───────────── 分钟 (0 - 59) -- │ ┌────────────── 小时 (0 - 23) -- │ │ ┌─────────────── 日期 (1 - 31) -- │ │ │ ┌──────────────── 月份 (1 - 12) -- │ │ │ │ ┌───────────────── 一周中的某一天 (0 - 6) (0 到 6 是 周日 到 周六，或者 使用名称; 7 也是周日) -- │ │ │ │ │ -- * * * * *

示例：

--每分钟执行一次插入selectcron.schedule('每分钟执行一次插入','* * * * *','insert into public.t1(v) values(''test'' || clock_timestamp()::timestamp(0)::text);');-- 每天上午9点40对表执行一次vacuum'selectcron.schedule('每天上午9点40对表执行一次vacuum','40 09 * * *','vacuum analyze public.t1;');--每周六的晚上23点执行一次vacuumselectcron.schedule('每周六的晚上23点执行一次vacuum','00 23 * * 6','vacuum analyze public.t1;');--一周自动执行一次vacuumselectcron.job_create('一周执行一次vacuum操作','vacuum;','1 week',now());--每隔5秒向表t1中插入一条记录selectcron.job_create('每隔5秒向表t1中插入一条记录','insert into public.t1(v) values(''test'' || clock_timestamp()::timestamp(0)::text);','5s',now());--每隔5分钟执行一次vacuum，并设定开始时间为当天的晚上22点selectcron.job_create('vacuum analyze;','5 min','2025-08-07 22:00:00');

2.查看定时任务

查询cron.job表，记录了所有的定时任务。

示例：

cron_db=>select*fromcron.job;jobid|nodeport|is_hgjob|schedule|command|first_run_time|nodename|database|username|interval|nex t_run_time|active|jobname-------+----------+----------+-------------+-----------------------------------------------------------------------------------+-------------------------------+-----------+----------+-----------+----------+-------------------------------+--------+---------------------------------1|5866|f|*****|insertintopublic.t1(v)values('test'||clock_timestamp()::timestamp(0)::text);||localhost|cron_db|cron_user|||t|每分钟执行一次插入2|5866|f|4009***|vacuumanalyzepublic.t1;||localhost|cron_db|cron_user|||t|每天上午9点40对表执行一次vacuum3|5866|f|0023**6|vacuumanalyzepublic.t1;||localhost|cron_db|cron_user|||t|每周六的晚上23点执行一次vacuum4|5866|t||vacuum;|2025-08-0714:34:46.564451+08|localhost|cron_db|cron_user|7days|2025-08-1414:34:47.300323+08|t|一周执行一次vacuum操作5|5866|t||insertintopublic.t1(v)values('test'||clock_timestamp()::timestamp(0)::text);|2025-08-0714:34:53.683297+08|localhost|cron_db|cron_user|00:00:05|2025-08-0714:36:34.737257+08|t|每隔5秒向表t1中插入一条记录(5行记录)

3.修改定时任务

pg_cron 1.3版本没有提供修改定时任务的函数，可以使用创建定时任务的函数通过传入相同的任务名称实现修改功能。

但是必须使用执行该定时任务的用户去修改，即cron.job表中的username。

示例：

--根据任务名称查询出任务信息cron_db=>select*fromcron.jobwherejobname='每天上午9点40对表执行一次vacuum';-[RECORD1]--+--------------------------------jobid|2nodeport|5866is_hgjob|f schedule|4009***command|vacuumanalyzepublic.t1;first_run_time|nodename|localhostdatabase|cron_db username|cron_userinterval|next_run_time|active|t jobname|每天上午9点40对表执行一次vacuum--修改定时计划为每天晚上22点30cron_db=>selectcron.schedule('每天上午9点40对表执行一次vacuum','30 22 * * *','vacuum analyze public.t1;');-[RECORD1]schedule|2--查看cron.job表，定时计划更新了cron_db=>select*fromcron.jobwherejobname='每天上午9点40对表执行一次vacuum';-[RECORD1]--+--------------------------------jobid|2nodeport|5866is_hgjob|f schedule|3022***command|vacuumanalyzepublic.t1;first_run_time|nodename|localhostdatabase|cron_db username|cron_userinterval|next_run_time|active|t jobname|每天上午9点40对表执行一次vacuum

4.查看定时任务执行情况

cron.job_run_details表记录了定时任务的执行情况，包括开始时间、结束时间、执行结果等。

示例：

cron_db=>select*fromcron.job_run_details;-[RECORD1]--+----------------------------------------------------------------------------------jobid|1runid|22job_pid|3425database|cron_db username|cron_user command|insertintopublic.t1(v)values('test'||clock_timestamp()::timestamp(0)::text);status|succeeded return_message|INSERT01start_time|2025-08-0714:30:00.823775+08end_time|2025-08-0714:30:00.83079+08

5.删除定时任务

使用cron.unschedule函数，支持按照jobid或者job名称删除。

按照job名称删除时，需要使用执行定时任务的用户删除，否则报错，而jobid可以使用sysdba用户删除，因有时也存在job名称为空的情况，所以推荐按照jobid删除。

示例：

cron_db=>selectcron.unschedule(10);unschedule------------t(1行记录)cron_db=>selectcron.unschedule('每隔5秒向表t1中插入一条记录');unschedule------------t(1行记录)

6.跨库创建定时任务

pg_cron 的1.3版本没有提供跨库创建定时任务的函数，但是可以通过更新cron.job表中的database和username实现此功能。需要使用sysdba用户执行。

示例：

--更新定时任务的数据库和用户cron_db=# update cron.job set database='cron_db_02',username='cron_user_02' where jobid=3;UPDATE1--查看修改后的定时任务cron_db=# select * from cron.job where jobid=3;-[RECORD1]--+-------------------------------jobid|3nodeport|5866is_hgjob|f schedule|*****command|vacuumanalyzepublic.t1;first_run_time|nodename|localhostdatabase|cron_db_02 username|cron_user_02interval|next_run_time|active|t jobname|每周六的晚上23点执行一次vacuum--查看定时任务执行结果，跨库执行成功cron_db=# select * from cron.job_run_details where jobid=3 order by end_time desc;-[RECORD1]--+----------------------------------jobid|3runid|780job_pid|19554database|cron_db_02 username|cron_user_02 command|vacuumanalyzepublic.t1;status|succeeded return_message|VACUUM start_time|2025-08-0809:38:00.242307+08end_time|2025-08-0809:38:00.260244+08