如何通过PostgreSQL触发器向后端HTTP服务器发送变更通知？

针对你的需求，PostgreSQL有几种成熟的方案可以替代轮询，实现数据库变更主动通知后端服务：

1. 触发器 + 外部过程语言（PL/Python/PL/Perl） #

这是最直接的实现方式：通过创建表级触发器，在INSERT/UPDATE操作触发时调用外部语言编写的函数，直接发起HTTP请求。

示例实现（PL/Python）： #

首先确保PostgreSQL已安装plpython3u扩展：

CREATE EXTENSION IF NOT EXISTS plpython3u;

然后创建触发函数，发送HTTP请求：

CREATE OR REPLACE FUNCTION notify_http()
RETURNS TRIGGER AS $$
import urllib.request
import json

def send_notification():
    url = "http://your-backend-server/webhook"
    payload = json.dumps({
        "action": TG_OP,
        "table": TG_TABLE_NAME,
        "data": dict(NEW)
    }).encode('utf-8')
    req = urllib.request.Request(url, data=payload, headers={'Content-Type': 'application/json'})
    try:
        urllib.request.urlopen(req, timeout=5)
    except Exception as e:
        # 记录错误，避免阻塞事务
        plpy.error(f"HTTP request failed: {str(e)}")

send_notification()
$$ LANGUAGE plpython3u;

最后给目标表绑定触发器：

CREATE TRIGGER after_table_change
AFTER INSERT OR UPDATE ON your_target_table
FOR EACH ROW EXECUTE FUNCTION notify_http();

注意点： #

• 同步HTTP请求会阻塞数据库事务，建议改用异步方式（比如将请求写入本地消息队列，再由外部进程处理）
• 需要确保PostgreSQL服务器能访问目标HTTP服务器
• PL/Python需要超级用户权限才能安装和使用

2. LISTEN/NOTIFY + 外部守护进程 #

利用PostgreSQL内置的LISTEN/NOTIFY机制，数据库只负责发送变更事件，由外部守护进程监听并转发HTTP请求，避免数据库直接处理网络请求。

步骤： #

1. 创建触发器发送NOTIFY事件：

CREATE OR REPLACE FUNCTION trigger_notify()
RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify(
        'table_change_events',
        json_build_object(
            'action', TG_OP,
            'table', TG_TABLE_NAME,
            'data', row_to_json(NEW)
        )::text
    );
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER after_table_change
AFTER INSERT OR UPDATE ON your_target_table
FOR EACH ROW EXECUTE FUNCTION trigger_notify();

2. 编写外部守护进程（以Python为例）：

import psycopg2
import psycopg2.extensions
import requests
import json

conn = psycopg2.connect("dbname=your_db user=your_user password=your_pass host=db_host")
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)

cur = conn.cursor()
cur.execute("LISTEN table_change_events;")

print("Listening for table change events...")
while True:
    conn.poll()
    while conn.notifies:
        notify = conn.notifies.pop(0)
        event_data = json.loads(notify.payload)
        # 发送HTTP请求到后端服务
        try:
            requests.post(
                "http://your-backend-server/webhook",
                json=event_data,
                timeout=5
            )
        except Exception as e:
            print(f"Failed to send HTTP request: {str(e)}")

优势： #

• 数据库事务不会被HTTP请求阻塞，性能影响更小
• 守护进程可以灵活处理重试、消息缓冲等逻辑
• 无需启用外部过程语言，权限要求更低

3. 逻辑复制（Logical Replication） #

对于高并发、需要可靠捕获所有变更的场景，逻辑复制是更专业的方案。PostgreSQL的逻辑复制可以将表的变更流发送到自定义订阅者，订阅者接收后再转发HTTP请求。

核心步骤： #

1. 启用数据库的逻辑复制功能（修改postgresql.conf）：

wal_level = logical
max_replication_slots = 10
max_wal_senders = 10

2. 创建发布者：

CREATE PUBLICATION table_changes FOR TABLE your_target_table;

3. 编写自定义订阅者程序（比如用Go的pgx库、Python的psycopg2逻辑复制接口），接收变更并发送HTTP请求。

优势： #

• 基于PostgreSQL的WAL日志，变更捕获完全可靠，不会丢失
• 支持增量同步，适合大规模数据场景
• 订阅者可以独立扩展，不影响数据库性能

通用注意事项 #

• 可靠性保障：直接发送HTTP请求可能因网络问题丢失消息，建议引入消息队列（如Redis、RabbitMQ）做缓冲，确保消息不丢失
• 幂等性：后端服务需要处理重复通知的情况，确保接口幂等
• 性能优化：避免在触发器中处理复杂逻辑，尽量将业务逻辑放到后端服务或外部进程中

内容的提问来源于stack exchange，提问作者Shiladitya Bose