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

用法

来源：README，database.dev page

pg_dispatch 是一个基于 pg_cron 的 TLE-compatible 异步 SQL dispatcher。它面向 RDS 或 Supabase 这类沙箱环境，用于把副作用操作延迟到调用者主事务之外执行。

依赖与安装

• PostgreSQL 13+
• pg_cron 1.5.0+
• pgcrypto

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

该扩展会安装到 pgdispatch schema。

主要函数

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

• pgdispatch.fire(command text)：将 SQL 放入队列并立即异步执行。
• pgdispatch.snooze(command text, delay interval)：将 SQL 放入队列并延迟异步执行。

典型用法

官方 README 将 pg_dispatch 定位于 PL/pgSQL 或 trigger 驱动的工作流：前台 RPC 需要快速提交，而通知、分析更新或其他昂贵 SQL 则在稍后的独立事务中执行。

注意事项

• 除了 pg_cron 之外，运行时还依赖 pgcrypto。
• delay 参数会被截断到秒级精度。
• 项目文档优先介绍 TLE/database.dev 安装方式；README 中也链接了手工 PGXN 安装方式。