pg_jobmon

pig build pkg pg_jobmon         # 构建 DEB 包

pig repo add pgsql -u          # 添加仓库并更新缓存

CREATE EXTENSION pg_jobmon CASCADE;  -- 依赖: dblink

CREATE SCHEMA jobmon;
CREATE EXTENSION pg_jobmon SCHEMA jobmon;

INSERT INTO jobmon.dblink_mapping_jobmon (username, pwd) VALUES ('rolename', 'rolepassword');

INSERT INTO jobmon.dblink_mapping_jobmon (host, username, pwd, port)
VALUES ('localhost', 'rolename', 'rolepassword', '5999');

-- 开始新作业
SELECT jobmon.add_job('My Job Name');

-- 向作业添加步骤
SELECT jobmon.add_step(job_id, 'Step description');

-- 更新步骤状态
SELECT jobmon.update_step(step_id, 'OK', 'Step completed successfully');
SELECT jobmon.update_step(step_id, 'WARNING', 'Something unexpected');

-- 关闭作业
SELECT jobmon.close_job(job_id);

-- 或标记作业失败
SELECT jobmon.fail_job(job_id);

-- 检查失败的作业
SELECT * FROM jobmon.check_job_status();

-- 查看作业历史
SELECT * FROM jobmon.job_log ORDER BY start_time DESC;

-- 查看步骤详情
SELECT * FROM jobmon.job_detail WHERE job_id = 123;