pg_dispatch

概览

Pure SQL extension; runtime also needs pgcrypto from contrib in addition to pg_cron.

版本

构建

您可以使用 pig build 命令构建 pg_dispatch 扩展的 RPM / DEB 包：

pig build pkg pg_dispatch         # 构建 RPM / DEB 包

安装

您可以直接安装 pg_dispatch 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：

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

使用 pig 或者是 apt/yum/dnf 安装扩展：

• 安装
• pig
• dnf
• apt

pig install pg_dispatch;          # 当前活跃 PG 版本安装

pig ext install -y pg_dispatch -v 18  # PG 18
pig ext install -y pg_dispatch -v 17  # PG 17
pig ext install -y pg_dispatch -v 16  # PG 16
pig ext install -y pg_dispatch -v 15  # PG 15
pig ext install -y pg_dispatch -v 14  # PG 14

dnf install -y pg_dispatch_18       # PG 18
dnf install -y pg_dispatch_17       # PG 17
dnf install -y pg_dispatch_16       # PG 16
dnf install -y pg_dispatch_15       # PG 15
dnf install -y pg_dispatch_14       # PG 14

apt install -y postgresql-18-pg-dispatch   # PG 18
apt install -y postgresql-17-pg-dispatch   # PG 17
apt install -y postgresql-16-pg-dispatch   # PG 16
apt install -y postgresql-15-pg-dispatch   # PG 15
apt install -y postgresql-14-pg-dispatch   # PG 14

创建扩展：

CREATE EXTENSION pg_dispatch CASCADE;  -- 依赖: pgcrypto, pg_cron

用法

语法：

CREATE EXTENSION "Snehil_Shah@pg_dispatch";
SELECT pgdispatch.fire('SELECT pg_sleep(40);');
SELECT pgdispatch.snooze('SELECT pg_sleep(20);', '20 seconds');

来源：README，database.dev 页面

pg_dispatch 是 PostgreSQL 的异步 SQL 调度器。它被设计为兼容 TLE 的 pg_later 替代方案，构建在 pg_cron 之上，因此可用于 Supabase 和 AWS RDS 等受限环境。

先决条件

上游 README 列出了以下要求：

• PostgreSQL 13 或更高版本
• pg_cron 1.5.0 或更高版本
• pgcrypto

安装

文档中给出的 TLE 安装路径如下：

SELECT dbdev.install(Snehil_Shah@pg_dispatch);
CREATE EXTENSION "Snehil_Shah@pg_dispatch";

README 提醒，该扩展会安装到 pgdispatch 模式中，如果系统里已经存在同名模式，可能会发生命名空间冲突。

函数

pgdispatch.fire(command text)

异步派发一条 SQL 命令：

SELECT pgdispatch.fire('SELECT pg_sleep(40);');

pgdispatch.snooze(command text, delay interval)

延迟派发一条 SQL 命令：

SELECT pgdispatch.snooze('SELECT pg_sleep(20);', '20 seconds');

README 指出，这个延迟调度是异步完成的，不会阻塞主事务。

适用场景

该项目主要用于数据库内的异步副作用，尤其适合 PL/pgSQL 或触发器流程。示例场景是把昂贵的通知或分析任务从 AFTER INSERT 触发器中拆出去，让主 RPC 或应用请求更快返回。