双集群容灾控制函数
- gs_streaming_dr_in_switchover()
描述：基于流式复制的异地容灾解决方案中主集群在执行计划内switchover过程中截断业务的接口。
返回值类型：Boolean，表明此次业务截断是否成功，是否可以正常进行switchover流程。
- gs_set_dr_dest_name()
描述：用于配置日志发送端集群的所有日志接收端集群实例ID，入参为与日志发送端集群直接连接的所有日志接收端集群实例ID拼接成的字符串，并以','作为间隔符；设置成功返回t，否则返回f。
入参类型：text，当入参为0时表示未配置日志接收端集群实例ID信息。容灾流程中会自动设置，不建议用户进行修改。
日志接收端集群实例ID不可为“invalid_cluster_uuid”，且字符长度不可超过36位。
返回值类型：boolean
示例
gaussdb=# SELECT * FROM gs_set_dr_dest_name('cluster1,cluster2'); gs_set_dr_dest_name --------------------- t (1 row) - gs_get_dr_dest_name()
描述：用于查看通过gs_set_dr_dest_name配置的所有日志接收端集群实例ID信息。
返回值类型：text，返回值为0时表示配置的日志接收端集群实例ID信息为空。
示例
gaussdb=# SELECT * FROM gs_get_dr_dest_name(); gs_get_dr_dest_name --------------------- cluster1,cluster2 (1 row)
- gs_set_hadr_link_info()
描述：用于容灾链路信息的设置，入参是JSON格式的text；设置成功返回"success"，失败则返回"failed"。容灾流程中会自动设置，不建议用户进行修改。
返回值类型：text
表1 gs_set_hadr_link_info参数说明 参数名
类型
描述
meta_version
string
容灾链路JSON格式的版本号。
version
string
容灾链路信息的版本号。
replication_info
string
存放容灾链路信息，包含多条链路信息的JSON数组。
dest_name
string
灾备集群实例ID。
dest_type
string
控制容灾链路的类型。
取值类型：枚举值
取值范围：physical_standby_cluster/logical_standby_cluster/gaussstor
默认值：physical_standby_cluster
mode
string
控制容灾链路日志同步的模式。
取值类型：枚举值
取值范围：- sync：该链路同步等待日志接收端备机持久化redo日志到磁盘，确保无数据丢失，会影响主机性能。
- semisync：该链路优先同步传输，若发生断链超时或RPO异常时则降级为异步。
- async：异步传输，优先主机性能。
默认值：async
net_timeout
string
半同步模式下超时阈值。
取值范围：[0,max]
取值单位：秒
默认值：0
rpo_threshold
int
半同步模式下RPO阈值。
取值范围：[0,max]
取值单位：秒
默认值：0
compression
string
控制是否打开压缩。
取值类型：枚举值
取值范围：enable/disable
默认值：enable
compression_algo_setting
string
控制压缩算法，当前不支持修改，此参数使用默认值"lz4,1"。
replication_rate_limit
int/string
控制容灾链路的限制速度，带单位：K、M、G，例如：1024K、1M、10M、2048G。
取值单位：Byte
取值范围：[-1、0、1MB ~ 2TB]- 整型：-1、0、1048576 ~ 2199023255552
- 字符串：-1、0、1048576 ~ 2199023255552
默认值：-1
rate_burst
int
控制允许单次发送的最大数据包大小，为replication_rate_limit的倍数关系。
取值范围：[1, 5]
默认值：2
conn_info
string
包含连接串和访问权限信息。详见下面示例的具体内容。
示例
gaussdb=# SELECT gs_set_hadr_link_info('{"meta_version":"1","version":"3","replication_info":[{"dest_name":"clusterb","dest_type":"physical_standby_cluster","mode":"async","net_timeout":0,"rpo_threshold":0,"compression":"enable","compression_algo_setting":"lz4,1","replication_rate_limit":-1,"rate_burst":2,"conn_info":{"shards":{"replconninfo":{"shard_1":{"localinfo":{"dn_6001":{"h":"127.0.0.1","p":40001,"hbp":40005},"dn_6002":{"h":"127.0.0.1","p":40001,"hbp":40005},"dn_6003":{"h":"127.0.0.1","p":40001,"hbp":40005}},"remoteinfo":[{"h":"127.0.0.1","p":40001,"hbp":40005},{"h":"127.0.0.1","p":40001,"hbp":40005},{"h":"127.0.0.1","p":40001,"hbp":40005}]},"shard_2":{"localinfo":{"dn_6006":{"h":"127.0.0.1","p":40021,"hbp":40025},"dn_6004":{"h":"127.0.0.1","p":40021,"hbp":40025},"dn_6005":{"h":"127.0.0.1","p":40021,"hbp":40025}},"remoteinfo":[{"h":"127.0.0.1","p":40021,"hbp":40025},{"h":"127.0.0.1","p":40021,"hbp":40025},{"h":"127.0.0.1","p":40021,"hbp":40025}]},"shard_3":{"localinfo":{"dn_6008":{"h":"127.0.0.1","p":40041,"hbp":40045},"dn_6009":{"h":"127.0.0.1","p":40041,"hbp":40045},"dn_6007":{"h":"127.0.0.1","p":40041,"hbp":40045}},"remoteinfo":[{"h":"127.0.0.1","p":40041,"hbp":40045},{"h":"127.0.0.1","p":40041,"hbp":40045},{"h":"127.0.0.1","p":40041,"hbp":40045}]}},"hba":[{"type":"host","database":"all","user":"rdsAdmin","method":"trust"},{"type":"host","database":"replication","user":"stream_user","method":"sha256"}]},"cn":{"replconninfo":{"cn_5001":{"h":"127.0.0.1","p":9081,"hbp":9085,"remoteinfo":[{"h":"127.0.0.1","p":9081,"hbp":9085}]},"cn_5002":{"h":"127.0.0.1","p":9081,"hbp":9085,"remoteinfo":[{"h":"127.0.0.1","p":9081,"hbp":9085}]},"cn_5003":{"h":"127.0.0.1","p":9081,"hbp":9085,"remoteinfo":[{"h":"127.0.0.1","p":9081,"hbp":9085}]}},"hba":[{"type":"host","database":"all","user":"rdsAdmin","method":"trust"},{"type":"host","database":"replication","user":"stream_user","method":"sha256"}]}}}]} '); gs_set_hadr_link_info ----------------------- success (1 row) - gs_get_hadr_link_info()
返回值类型：record
示例
gaussdb=# SELECT * FROM gs_get_hadr_link_info(); -[ RECORD 1 ]------------+----------------------------------------------------------------------------------------------------------------------------- dest_name | clusterb dest_type | physical_standby_cluster mode | semisync net_timeout | 60 rpo_threshold | 10 compression | enable compression_algo_setting | lz4,1 replication_rate_limit | 0 rate_burst | 2 replconninfo | localhost=127.0.0.1 localport=20001 localheartbeatport=20005 remotehost=127.0.0.1 remoteport=20025 remoteheartbeatport=20029 | localhost=127.0.0.1 localport=20001 localheartbeatport=20005 remotehost=127.0.0.1 remoteport=20033 remoteheartbeatport=20037 | localhost=127.0.0.1 localport=20001 localheartbeatport=20005 remotehost=127.0.0.1 remoteport=20041 remoteheartbeatport=20045 | hba | local all all trust | local all all trust | local all all trust | - gs_get_hadr_link_version()
返回值类型：int8
示例
gaussdb=# SELECT * FROM gs_get_hadr_link_version(); link_info_version ------------------- 100 (1 row) - gs_get_hadr_sync_status()
返回值类型：record
表2 gs_get_hadr_sync_status参数说明 参数类型
参数名
类型
描述
输出参数
dest_name
text
容灾链路日志接收端集群ID。
输出参数
sync_state
text
当前容灾链路实际的同步状态。
输出参数
current_rpo
int
当前容灾链路的RPO时间（单位：秒）。
输出参数
sender_sent_location
text
容灾链路日志发送端发送日志位置。
输出参数
sender_write_location
text
容灾链路日志发送端写入到文件系统的日志位置。
输出参数
sender_flush_location
text
容灾链路日志发送端flush磁盘的日志位置。
输出参数
sender_replay_location
text
容灾链路日志发送端回放日志位置。
输出参数
receiver_received_location
text
容灾链路日志接收端接收日志位置。
输出参数
receiver_flush_location
text
容灾链路日志接收端日志flush磁盘位置。
输出参数
last_disconnect_time
timestamptz
最近一次容灾链路断链的时间。
输出参数
last_upgrade_to_sync_time
timestamptz
半同步模式下，最近一次升级为同步模式的时间。
输出参数
last_downgrade_to_async_time
timestamptz
半同步模式下，最近一次降级为异步模式的时间。
输出参数
mode
text
容灾链路日志同步模式的配置值。
输出参数
net_timeout
text
容灾链路半同步模式的超时阈值。
输出参数
rpo_threshold
text
容灾链路半同步模式的RPO阈值。
示例
gaussdb=# SELECT * FROM gs_get_hadr_sync_status(); -[ RECORD 1 ]----------------+------------------------------ dest_name | clusterb sync_state | Sync current_rpo | 0 sender_sent_location | 0/11380B20 sender_write_location | 0/11380B20 sender_flush_location | 0/11380B20 sender_replay_location | 0/11380B20 receiver_received_location | 0/11380B20 receiver_flush_location | 0/11380B20 last_disconnect_time | 2026-01-15 20:35:42.18516+08 last_upgrade_to_sync_time | 2026-01-15 21:29:55.147578+08 last_downgrade_to_async_time | 2026-01-15 20:36:42.187545+08 mode | semisync net_timeout | 60 rpo_threshold | 10
- gs_stat_get_replication_limit()
描述：用于查询当前集群所有链路的限流配置参数值，最近1s、最近5s和最近60s的平均带宽使用情况。
返回值类型：record
表3 gs_stat_get_replication_limit参数说明 参数类型
参数名
类型
描述
输出参数
dest_name
text
该发送链路的目标集群名称。
输出参数
replication_rate_limit
text
该链路限流配置的带宽上限。
输出参数
rate_burst
text
该链路限流配置的突发流量为带宽上限的倍数，允许瞬时产生的最大流量。
输出参数
current_usage
text
最近1s链路使用的平均带宽统计，单位Byte/s。
输出参数
average_usage_5s
text
最近5s链路使用的平均带宽统计，单位Byte/s。
输出参数
average_usage_60s
text
最近60s链路使用的平均带宽统计，单位Byte/s。
示例
gaussdb=# SELECT * FROM gs_stat_get_replication_limit(); -[ RECORD 1 ]----------+--------- dest_name | clusterb replication_rate_limit | -1 rate_burst | 2 current_usage | 0 average_usage_5s | 0 average_usage_60s | 0 -[ RECORD 2 ]----------+--------- dest_name | clusterc replication_rate_limit | -1 rate_burst | 2 current_usage | 0 average_usage_5s | 0 average_usage_60s | 0
