背景

阿里云RDS PG 11 云盘版开放相同vpc的实例间的dblink, postgres_fdw功能。相同vpc内如果有自建的pg实例,也可以被访问,如果要访问vpc外部的其他实例,通过相同vpc内ecs的端口跳转也能实现。

阿里云RDS PG 11 云盘版购买入口:

https://rds-buy.aliyun.com/rdsBuy?spm=5176.7920951.1393245.1.41c64ce1pOvLll&aly_as=JoVfjAtF#/create/rds?initData=%7B%22data%22:%7B%22rds_dbtype%22:%22PostgreSQL%22%7D%7D

支持距离

rds pg 11 (postgres_fdw , dblink) 可以访问如下:

1、same vpc ecs/rds pg

2、same vpc ecs(端口转发) -> other vpc/network pg

3、same vpc ecs(自建pg+oracle_fdw,mysql_fdw) -> other vpc\/network oracle|mysql

rds pg 11 (将支持oracle_fdw, mysql_fdw) 可以访问如下:

1、same vpc ecs(oracle, mysql)\/rds mysql

2、same vpc ecs(端口转发) -> other vpc\/network mysql|oracle

通过同vpc内ecs的端口转发功能,可以访问ecs可以访问的任意目标。(只要ecs能访问的,rds pg就可以通过这个端口代理去访问)

端口转发见本文参考部分。

例子


1. postgres=> select dblink_connect('a', 'host=同一vpc下的另一rds的内网域名 port=同一vpc下的另一rds的内网监听端口 user=远程数据库用户名 password=密码 dbname=库名');
2. dblink_connect
3. ----------------
4. OK
5. (1 row)

7. postgres=> select version();
8. version
9. -----------------
10. PostgreSQL 11.5
11. (1 row)

13. postgres=> SELECT * FROM dblink('a', 'SELECT version()') as t(ver text);
14. ver
15. ------------------
16. PostgreSQL 10.10
17. (1 row)

postgres_fdw例子

新建一个数据库


1. postgres=> create database db1;
2. CREATE DATABASE

4. postgres=> \c db1

新建postgres_fdw插件


1. db1=> create extension postgres_fdw;
2. CREATE EXTENSION

新建远程数据库server


1. db1=> CREATE SERVER foreign_server
2. FOREIGN DATA WRAPPER postgres_fdw
3. OPTIONS (host '同一vpc下的另一rds的内网域名 port=同一vpc下的另一rds的内网监听端口', port '同一vpc下的另一rds的内网监听端口', dbname '库名');
4. CREATE SERVER

6. db1=> CREATE USER MAPPING FOR digoal
7. SERVER foreign_server
8. OPTIONS (user '远程数据库用户', password '密码');
9. CREATE USER MAPPING

导入外部表


1. db1=> import foreign schema public from server foreign_server into ft;
2. IMPORT FOREIGN SCHEMA

4. db1=> \det ft.*
5. List of foreign tables
6. Schema |       Table        |     Server
7. --------+--------------------+----------------
8. ft     | customer1          | foreign_server
9. ft     | district1          | foreign_server
10. ft     | ha_health_check    | foreign_server
11. ft     | history1           | foreign_server
12. ft     | item1              | foreign_server
13. ft     | new_orders1        | foreign_server
14. ft     | order_line1        | foreign_server
15. ft     | orders1            | foreign_server
16. ft     | pg_stat_statements | foreign_server
17. ft     | stock1             | foreign_server
18. ft     | warehouse1         | foreign_server
19. (11 rows)

参考

https://www.postgresql.org/docs/12/postgres-fdw.html

https://www.postgresql.org/docs/12/dblink.html

《使用 ssh -R 建立反向/远程TCP端口转发代理》

《使用 ssh -R 建立反向/远程TCP端口转发代理》

《一个端口代理软件 - inlab balance》

原文:http://mysql.taobao.org/monthly/2019/10/09/