Postgresql主从复制有延迟，但pgpool仍将流量发送到主数据库和从数据库。

要解决PostgreSQL主从复制延迟问题，可以使用pgpool来控制流量的分发。下面是一个使用pgpool来实现主从复制延迟感知的示例代码：

首先，在pgpool的配置文件（通常是pgpool.conf）中，找到并编辑以下参数：

delay_threshold = 100    # 设置主从复制延迟的阈值（单位：毫秒）

接下来，在应用程序中添加以下代码来实现主从复制延迟感知：

import psycopg2

# 连接到pgpool
conn = psycopg2.connect("host=pgpool_ip_address port=pgpool_port user=pgpool_username password=pgpool_password")

# 执行SQL查询以获取当前主数据库和从数据库的连接状态
cursor = conn.cursor()
cursor.execute("SHOW pool_nodes")
rows = cursor.fetchall()

# 检查每个数据库的延迟时间，并将流量发送到延迟低的数据库
for row in rows:
    node_id = row[0]
    host = row[1]
    port = row[2]
    status = row[9]
    delay = row[10]

    if status == 'up' and delay < delay_threshold:
        # 连接到主/从数据库
        db_conn = psycopg2.connect("host={} port={} user=postgres password=postgres".format(host, port))
        # 执行查询语句
        # ...
        # 关闭数据库连接
        db_conn.close()

# 关闭pgpool连接
conn.close()

上述代码通过连接到pgpool并执行SHOW pool_nodes查询来获取主从数据库的连接状态。然后，在循环中检查每个数据库的延迟时间，并将流量发送到延迟低的数据库。

请确保将代码中的pgpool_ip_address、pgpool_port、pgpool_username和pgpool_password替换为实际的pgpool连接信息，并将postgres替换为实际的主/从数据库连接信息。

这样，当主从复制延迟超过阈值时，pgpool将自动将流量发送到延迟较低的数据库，以确保数据的一致性和可用性。