postgres pg_cron 扩展试用

Posted 2021-03-08 rongfengliang

就是一个简单的试用，同时测试下docker 基础镜像

环境准备

• docker-compose 文件

version: ‘3‘

services:

  pgspider-pg_cron:

    image: dalongrong/pgspider:pg_cron

    ports: 

    - "5432:5432"

    environment: 

    - "POSTGRES_PASSWORD=dalong"

使用

• 简单需求
  每分钟insert 数据到一张表中,表结构

 

CREATE TABLE apps (

    id SERIAL PRIMARY KEY,

    insert_date timestamp without time zone

);

• 启动扩展

CREATE EXTENSION pg_cron;

• 创建调度任务

SELECT cron.schedule(‘* * * * *‘,‘insert into apps(insert_date) values(now())‘);

• 查看任务

SELECT * FROM cron.job;

• 删除任务

SELECT cron.unschedule(cronid) FROM cron.job;

• 一个效果

 

 

一些参考玩法

https://www.citusdata.com/blog/2016/09/09/pgcron-run-periodic-jobs-in-postgres/
https://www.citusdata.com/blog/2017/12/27/real-time-analytics-dashboards-with-citus/
https://www.citusdata.com/blog/2018/01/24/citus-and-pg-partman-creating-a-scalable-time-series-database-on-PostgreSQL/

说明

pg_cron可以并行运行多个作业，但是一次最多只能运行一个作业实例。如果第二轮运行应在第一轮运行完成之前开始，
则第二轮运行将排队，并在第一轮运行完成后立即开始

参考资料

https://crontab.guru/
https://github.com/rongfengliang/pgspider-docker
https://github.com/citusdata/pg_cron