redis
从PG向Redis发送Pub/Sub消息
仓库
brettlaforge/pg_redis_pubsub
https://github.com/brettlaforge/pg_redis_pubsub
源码
pg_redis_pubsub-0.0.1.tar.gz
pg_redis_pubsub-0.0.1.tar.gz
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
pg_redis_pubsub | 0.0.1 | FDW | MIT | C |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 8720 | redis | 否 | 是 | 否 | 是 | 否 | 是 | - |
| 相关扩展 | redis_fdw spat pgmemcache pg_net wrappers kafka_fdw pgmq multicorn |
|---|
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | PIGSTY | 0.0.1 | 1817161514 | pg_redis_pubsub | - |
| RPM | PIGSTY | 0.0.1 | 1817161514 | pg_redis_pubsub_$v | - |
| DEB | PIGSTY | 0.0.1 | 1817161514 | postgresql-$v-pg-redis-pubsub | - |
构建
您可以使用 pig build 命令构建 pg_redis_pubsub 扩展的 RPM / DEB 包：
pig build pkg pg_redis_pubsub # 构建 RPM / DEB 包
安装
您可以直接安装 pg_redis_pubsub 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：
pig repo add pgsql -u # 添加仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展：
pig install pg_redis_pubsub; # 当前活跃 PG 版本安装
pig ext install -y pg_redis_pubsub -v 18 # PG 18
pig ext install -y pg_redis_pubsub -v 17 # PG 17
pig ext install -y pg_redis_pubsub -v 16 # PG 16
pig ext install -y pg_redis_pubsub -v 15 # PG 15
pig ext install -y pg_redis_pubsub -v 14 # PG 14
dnf install -y pg_redis_pubsub_18 # PG 18
dnf install -y pg_redis_pubsub_17 # PG 17
dnf install -y pg_redis_pubsub_16 # PG 16
dnf install -y pg_redis_pubsub_15 # PG 15
dnf install -y pg_redis_pubsub_14 # PG 14
apt install -y postgresql-18-pg-redis-pubsub # PG 18
apt install -y postgresql-17-pg-redis-pubsub # PG 17
apt install -y postgresql-16-pg-redis-pubsub # PG 16
apt install -y postgresql-15-pg-redis-pubsub # PG 15
apt install -y postgresql-14-pg-redis-pubsub # PG 14
创建扩展：
CREATE EXTENSION redis;
用法
redis 扩展（pg_redis_pubsub）允许 PostgreSQL 向 Redis 发布/订阅频道发布消息。目前仅支持发布端。
配置
通过 GUC 变量设置 Redis 连接参数：
ALTER SYSTEM SET redis.host = '127.0.0.1';
ALTER SYSTEM SET redis.port = '6379';
SELECT pg_reload_conf();
也可以在数据库、角色或会话级别设置：
SET redis.host = '127.0.0.1';
SET redis.port = '6379';
基本用法
CREATE EXTENSION redis;
SELECT redis_connect();
SELECT redis_publish('mychannel', 'Hello World');
SELECT redis_disconnect();
可用函数
| 函数 | 描述 |
|---|---|
redis_connect() | 使用 redis.host 和 redis.port 设置连接 Redis |
redis_disconnect() | 断开 Redis 连接 |
redis_publish(channel text, message text) | 在指定频道发布消息 |
redis_status() | 返回 Redis 客户端状态 |
注意：redis_publish 在没有连接时会自动连接。
触发器示例
当表被修改时向 Redis 发布变更事件：
CREATE OR REPLACE FUNCTION notify_changes()
RETURNS TRIGGER AS $$
BEGIN
PERFORM redis_publish(
'products:' || NEW.id::text,
to_jsonb(NEW)::text
);
RETURN NULL;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER on_product_change
AFTER INSERT OR UPDATE ON products
FOR EACH ROW EXECUTE PROCEDURE notify_changes();
这允许监听 Redis 频道的外部订阅者实时响应 PostgreSQL 数据变更。