AnalyticDB:pg_cron

基本的なスケジュール

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

例：

-- 毎週土曜日の午前 3:30 GMT に 1 週間以上前のイベントを削除
SELECT cron.schedule('30 3 * * 6', $$DELETE FROM events WHERE event_time < now() - interval '1 week'$$);

-- 毎日午前 10:00 GMT に test() ファンクションを呼び出し
SELECT cron.schedule('0 10 * * *', 'select test()');

-- 毎分 SQL ステートメントを実行
SELECT cron.schedule('* * * * *', 'select 1');

-- 毎月 1 日と 30 日、および毎週土曜日と日曜日の午前 2:30 GMT に VACUUM FULL を実行
SELECT cron.schedule('30 2 1,30 * 6,0', 'VACUUM FULL');

名前付きジョブのスケジュール

名前を割り当てると、後でジョブを識別および管理しやすくなります。

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

例：

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');

特定のデータベースでのジョブのスケジュール

1.4 より前の pg_cron バージョンでは、ジョブは拡張機能がインストールされているデータベースでのみ実行できました。他のデータベースでジョブを実行するには、cron.job テーブルを直接操作する必要があり、不便かつ安全ではありませんでした。pg_cron バージョン 1.4 以降では、cron.schedule() で対象データベースとアカウントを直接指定できます。

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

例：

-- dw データベースで毎日午後 11:00 GMT に VACUUM FULL を実行
SELECT cron.schedule('Do Vacuum', '0 23 * * *', 'VACUUM FULL', 'dw');

-- gp1234 として dw データベースで毎分 SQL ステートメントを実行
SELECT cron.schedule('Select Per Minute', '* * * * *', 'select 1', 'dw', 'gp1234');

-- user1 として dw データベースで毎日午前 10:00 GMT に test() を呼び出し
SELECT cron.schedule('DO Function', '0 10 * * *', 'select test()', 'dw', 'user1', true);

ジョブ名による削除

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

例：

SELECT cron.unschedule('Do Vacuum');

ジョブ ID による削除

SELECT cron.unschedule(<job_id>);

例：

SELECT cron.unschedule(21);

ジョブ ID は cron.job テーブルで確認できます。