pgspider redis fdw pub && sub 试用
redis fdw 封装的redis 操作功能还是比较强大的,同时支持通过insert 的方式publish messag
以下是一个简单的学习(但是按照原理应该也是可以sub的 (select message,细节可以看看源码))
环境准备
- dockerc-compose 文件
version: "3"
services:
redis:
image: redis
ports:
- "6379:6379"
pg-redis:
image: dalongrong/pgspider:redis
ports:
- "5432:5432"
environment:
- "POSTGRES_PASSWORD:dalong"
使用
- 启动服务
docker-compose up -d
- 扩展使用
// 创建扩展
CREATE EXTENSION redis_fdw;
// 创建server
CREATE SERVER redis_server
FOREIGN DATA WRAPPER redis_fdw
OPTIONS (host 'redis', port '6379');
// 创建用户映射
CREATE USER MAPPING FOR postgres
SERVER redis_server
OPTIONS (password 'demo');
// 创建表映射
CREATE FOREIGN TABLE rft_pub(
channel TEXT,
message TEXT,
len INT
) SERVER redis_server
OPTIONS (tabletype 'publish');
- redis-cli 订阅处理
redis-cli
SUBSCRIBE demoapps
- 效果
插入数据:
insert into rft_pub(channel,message) values('demoapp','dalong');
说明
redis fdw 的扩展功能还是比较强大,后边可以仔细研究下代码的实现