瀚高数据库使用pg_cron定时任务

Posted 2022-06-27 瀚高PG实验室

目录
环境
文档用途
详细信息

环境
系统平台：Linux x86-64 Red Hat Enterprise Linux 7
版本：4.5
文档用途
使用定时任务pg_cron插件

详细信息
1、参数配置及说明
– 参数说明：

– 参数名 功能 默认值 需要重启

– cron.database_name 定时任务元信息所在的数据库 highgo 是

– cron.log_statement 执行任务前，是否将sql打印到日志 true 是

– cron.log_run 是否将任务的执行信息存储到job_run_details表中 true 是

– cron.host 要执行定时任务的host名 localhost 是

– cron.use_background_workers 使用后台work进程，而非客户端连接执行任务 false（457 true） 是

– cron.max_running_jobs 可以同时运行的job数量 5 是

– 注意：

– 1.3 及以上的版本，支持参数cron.log_run和cron.use_background_workers;

– 1.3 及以上的版本，设置cron.use_background_workers为true后，cron.host不再生效，使用起来更加方便；

– 使用前，需要将cron.database_name修改为创建定时任务的数据库；

– 使用sysdba连接test(需要使用定时任务的数据库)执行共享库预加载设置添加pg_cron（注意：添加前show shared_preload_libraries; 看一下当前值设置是否有值，有值用逗号隔开追加在后边）

psql test sysdba

alter system set shared_preload_libraries to pg_cron;

– 配置定时任务数据库

alter system set cron.database_name to test; --（默认为highgo库，配置其它库需要重启数据库）

– 切换syssso登录

\\c - syssso

– 关闭数据库三权开关

select set_secure_param(‘hg_sepofpowers’,‘off’);

– 退出psql

\\q

– 重启数据库

pg_ctl restart 或者 systemctl restart hgdb-xxx-x.x.x.service 或者 service hgdb-xxx-x.x.x.service restart（注意：pg_ctl命令和服务不能同时使用）

– 重启数据库后使用sysdba登录

psql test sysdba

– 建立插件

create extension pg_cron;

– 并赋模式权限给普通用户使用

grant usage on schema cron to test;

– 开启三权

select set_secure_param(‘hg_sepofpowers’,‘on’);

– 退出psql

\\q

– 重启数据库

pg_ctl restart 或者 systemctl restart hgdb-xxx-x.x.x.service 或者 service hgdb-xxx-x.x.x.service restart（注意：pg_ctl命令和服务不能同时使用）

– 重启后使用普通用户登录数据库

psql test test

– 查看pg_cron插件提供的函数。

highgo=# \\df cron.

                                                             函数列表

架构模式 | 名称 | 结果数据类型 | 参数数据类型 | 类型

----------±---------------------±-------------±---------------------------------------------------------------------------------±-----

cron | job_cache_invalidate | trigger | | 函数

cron | job_create | bigint | jobname name, jwhat text, jinterval interval, jstartrun timestamp with time zone| 函数

cron | job_create | bigint | jwhat text, jinterval interval | 函数

cron | job_create | bigint | jwhat text, jinterval interval, jstartrun timestamp with time zone | 函数

cron | schedule | bigint | job_name name, schedule text, command text | 函数

cron | schedule | bigint | schedule text, command text | 函数

cron | unschedule | boolean | job_id bigint | 函数

cron | unschedule | boolean | job_name name | 函数

(8 行记录)

– 创建测试表

create table test_pg_cron (id bigserial ,time timestamp);

– 注意事项

– pg_cron需要后台守护进程，因此启动数据库前，需要将pg_cron放到shared_preload_libraries中;

– 定时任务不会在备机上运行，但当备机升主后，定时任务会自动启动；

– 定时任务会以任务创建者的权限执行；

– 一个实例可以并行运行多个任务，但同一时间某个任务仅能运行一个；

– 某个任务，需要等待前一个定时任务结束，那么该任务会进入等待队列，且会在前一个任务结束后尽快启动；

– job_create 参数说明：

– jobname 定时任务名称

– jwhat 定时执行的语句或者块

– jinterval 执行的间隔时间（秒（sec）分钟（min） 小时（hour） 天（day） 月（month) 年（year））

– jstartrun 何时开始执行

– schedule 参数说明：

– job_name 定时任务名称

– schedule 工作计划（* * * * *）如下：

– ┌───────────── min (0 - 59)

– │ ┌────────────── hour (0 - 23)

– │ │ ┌─────────────── day of month (1 - 31)

– │ │ │ ┌──────────────── month (1 - 12)

– │ │ │ │ ┌───────────────── day of week (0 - 6) (0 to 6 are Sunday to

– │ │ │ │ │ Saturday, or use names; 7 is also Sunday)

– * * * * *

– command 定时执行的语句

– 注意

– 1.定时任务使用GMT时间执行；

– 2.使用 crontab.guru 工具，可以方便地创建任务调度规则；

– unschedule 参数说明：

– job_id 定时任务id

– job_name 定时任务名称

– 下面介绍job_create使用，当定时任务名称存在时会更新存在的定时任务

– 定点执行，每天的当前时间执行

select cron.job_create(‘从现在开始每隔一天插入一次数据’,‘insert into test_pg_cron (time) values(now())’,‘1 d’,now());

– 每隔一分钟执行

select cron.job_create(‘从现在开始每隔1分钟插入一次数据’,‘insert into test_pg_cron (time) values(now())’,‘1 m’,now());

– 每隔3秒钟执行

select cron.job_create(‘从现在开始每隔3秒钟插入一次数据’,‘insert into test_pg_cron (time) values(now())’,‘3 s’,now());

– 查看测试表

select * from test_pg_cron;

– 查看任务

select * from cron.job;

– 查看任务执行记录

select * from cron.job_run_details;

– 下面介绍schedule使用，当定时任务名称存在时会更新存在的定时任务

– 每次重启数据库执行

select cron.schedule(‘重启数据库跟新pg_cron插件’, ‘@reboot’, ‘alter extension pg_cron update’);

– 每隔一分钟执行

select cron.job_create(‘从现在开始每隔1分钟插入一次数据’,’* * * * *’,‘insert into test_pg_cron (time) values(now())’);

– 注意：job_create schedule两者选其一执行即可，两者同时操作一条数据不排除执行两边的可能，schedule执行按照gmt时间会比北京时间晚8小时执行。

– 删除任务

– 根据定时任务id删除

select cron.unschedule(3);

– 根据定时任务名称删除

select cron.unschedule(‘每隔1分钟插入一次数据’);

2、执行结果：