RDS PostgreSQL提供pg_cron插件，可以设置定时任务。

前提条件

实例为RDS PostgreSQL 11。
说明 仅新购实例支持，存量实例请提交工单开通。

背景信息

pg_cron是基于cron的作业调度插件，与常规cron保持相同的语法，但它可以直接从数据库安排PostgreSQL命令。

每一个定时任务分为两部分：

  • 定时计划

    规定了用户使用插件的计划，例如每隔1分钟执行一次该任务。

  • 定时任务

    用户具体的任务内容，例如select * from some_table。

语法

pg_cron使用标准的cron语法，其中*表示任意时间都运行，特定数字表示仅在这个数字时运行。 

 ┌───────────── 分钟 (0 - 59)
 │ ┌────────────── 小时 (0 - 23)
 │ │ ┌─────────────── 日期 (1 - 31)
 │ │ │ ┌──────────────── 月份 (1 - 12)
 │ │ │ │ ┌───────────────── 一周中的某一天 (0 - 6) (0表示周日）
 │ │ │ │ │                  
 │ │ │ │ │
 │ │ │ │ │
 * * * * *

示例

  • 创建插件 
    CREATE EXTENSION pg_cron;
  • 增加任务项 
    -- 周六3:30am (GMT) 删除过期数据。 
SELECT cron.schedule('30 3 * * 6', $$DELETE FROM events WHERE event_time < now() - interval '1 week'$$);

----------

-- 每天的10:00am (GMT) 执行磁盘清理。
SELECT cron.schedule('0 10 * * *', 'VACUUM');

----------

-- 每分钟执行指定脚本。
SELECT cron.schedule('* * * * *', 'select 1;')；

----------

-- 每个小时的23分执行指定脚本。
SELECT cron.schedule('23 * * * *', 'select 1;')；

----------

-- 每个月的4号执行指定脚本。
SELECT cron.schedule('* * 4 * *', 'select 1;')；
  • 查看当前任务 
    SELECT * FROM cron.job;

 jobid | schedule   |  command  | nodename  | nodeport | database | username | active 
-------+------------+-----------+-----------+----------+----------+----------+--------
    43 | 0 10 * * * |   VACUUM; | localhost |     5433 | postgres | test     | t
  • 删除任务项 
    SELECT cron.unschedule(43);
    说明 43为jobid。