멋지게 놀아라

pg_cron : https://access.crunchydata.com/documentation/pg_cron/1.3.1/

위의 문서를 보면 pg 9.5 이상부터 사용할 수 있다고 나오는데, 최신버전으로 컴파일 해 보면 V10부터 사용이 가능하다.

테스트 환경은 V9.3 ~ V14까지 source를 이용하여 하나의 서버에 설치 된 상태이다.

pg_cron을 rpm을 이용하여 설치 할 경우 source코드를 컴파일 해서 설치 하였으므로, PostgreSQL Server가 설치 되어 있지 않다고 하면서 설치가 진행이 되질 않는다.

그래서 source 컴파일을 하는 방식으로 진행을 함

postgres 유저에게 sudo 권한을 부여한 후에 postgres유저로 Engine Home을 변경해 가면서 설치 진행

여러 버전을 컴파일 해야 하므로, pg_cron 원본을 하나 따로 만들어 놓고, Engine(버전) 변경 시 마다 pg_cron 디렉터리를 새로 생성하면서 컴파일 진행

1. Download

2. pg_cron 설치

3. pg_cron 사용하기

postgresql.conf 파일에 설정을 하고 기동을 하게 되면, pg_cron launcher라는 프로세스가 기동되는 것을 확인 할 수 있다.

사용 설정은 O/S의 cron과 설정 방법이 같다

create extension을 수행하게 되면, cron 스키마가 생성이 되고, 등록 된 Job과 Job 수행결과를 확인 할 수 있는 테이블 과 Job 등록 및 삭제를 할 수 있는 프로시저를 가지게 된다.

나중에 Job을 삭제 하기 편하기 위해서 job name을 이용하여 잡을 생성하고 삭제를 진행 하도록 하자

기본으로 cron 스키마가 postgres에 설치 되었기 때문에 postgres DB에서 기본적으로 실행이 된다.

다른 DB에서 수행해야 할 명령을 Job으로 생성하려면, schedule_in_database 프로시저를 이용해서 database 이름과 username을 입력해 주면 동작 된다.

3.1 postgres DB에서 사용하기

-- 테스트 테이블 생성

create table test_cron ( id serial , insertdate timestamp ) ;

-- 현재 시간 확인

select now() ;

+-------------------------------+

|              now              |

+-------------------------------+

| 2022-05-13 10:46:21.162693+09 |

+-------------------------------+

-- Job 생성

select cron.schedule('test_cron_insert' , '50 * * * *' , $$insert into test_cron(insertdate) values (now()) $$) ;

+----------+

| schedule |

+----------+

|        5 |

+----------+

-- Job 동작 확인

SELECT * FROM cron.job_run_details WHERE jobid = 5 ;

+-------+-------+---------+----------+----------+---------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

| jobid | runid | job_pid | database | username |                      command                      |  status   | return_message |          start_time           |           end_time            |

+-------+-------+---------+----------+----------+---------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

|     5 |     4 |   22283 | postgres | postgres | insert into test_cron(insertdate) values (now())  | succeeded | INSERT 0 1     | 2022-05-13 10:50:00.260626+09 | 2022-05-13 10:50:00.264431+09 |

+-------+-------+---------+----------+----------+---------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

select * from test_cron ;

+----+---------------------------+

| id |        insertdate         |

+----+---------------------------+

|  1 | 2022-05-13 10:50:00.26082 |

+----+---------------------------+

3.2 다른 데이터베이스에서 사용하기

-- 데이터 베이스 변경

\c test

select current_database() , current_user ;

+------------------+--------------+

| current_database | current_user |

+------------------+--------------+

| test             | postgres     |

+------------------+--------------+

-- 테스트 테이블 생성

create table test_cron_test ( id serial , insertdate timestamp ) ;

-- Job 생성 (postgres DB에서 생성)

/c postgres

select current_database() , current_user ;

+------------------+--------------+

| current_database | current_user |

+------------------+--------------+

| postgres         | postgres     |

+------------------+--------------+

select cron.schedule_in_database('test_cron_insert1' , '57 * * * *' , $$insert into test_cron_test(insertdate) values (now()) $$ , 'test', 'postgres') ;

+----------------------+

| schedule_in_database |

+----------------------+

|                    6 |

+----------------------+

SELECT * FROM cron.job_run_details WHERE jobid = 6 ;

+-------+-------+---------+----------+----------+--------------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

| jobid | runid | job_pid | database | username |                        command                         |  status   | return_message |          start_time           |           end_time            |

+-------+-------+---------+----------+----------+--------------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

|     6 |     5 |   22302 | test     | postgres | insert into test_cron_test(insertdate) values (now())  | succeeded | INSERT 0 1     | 2022-05-13 10:57:00.049459+09 | 2022-05-13 10:57:00.052424+09 |

+-------+-------+---------+----------+----------+--------------------------------------------------------+-----------+----------------+-------------------------------+-------------------------------+

-- Job 동작 확인

\c test

select * from test_cron_test ;

+----+----------------------------+

| id |         insertdate         |

+----+----------------------------+

|  1 | 2022-05-13 10:57:00.049657 |

+----+----------------------------+

3.3 Job 삭제

\c postgres

select cron.unschedule('test_cron_insert') ;

+------------+

| unschedule |

+------------+

| t          |

+------------+

select cron.unschedule('test_cron_insert1') ;

+------------+

| unschedule |

+------------+

| t          |

+------------+

DELETE FROM cron.job_run_details ;