多应用共用PostgreSQL 9.x，能否通知Django 2.2.x表变更？

根据你的限制条件（不能用cron、无法修改Java应用、不能安装pgsql-http），下面几个基于PostgreSQL原生功能和Django自身特性的方案应该能满足需求：

方案1：PostgreSQL LISTEN/NOTIFY + Django后台监听进程（实时通知） #

这是最直接的原生方案，不需要任何第三方插件，完全依赖PostgreSQL的消息通知机制和Django的数据库连接能力。

步骤1：在PostgreSQL中创建触发器发送通知 #

首先在数据库中定义一个触发器函数，当目标表发生INSERT/UPDATE/DELETE操作时，向指定频道发送通知：

-- 创建通知函数
CREATE OR REPLACE FUNCTION notify_table_change()
RETURNS TRIGGER AS $$
BEGIN
    -- 发送通知，payload包含表名和操作类型（INSERT/UPDATE/DELETE）
    PERFORM pg_notify('table_change_channel', TG_TABLE_NAME || ':' || TG_OP);
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

-- 给需要监控的表绑定触发器（以users表为例）
CREATE TRIGGER trigger_users_change
AFTER INSERT OR UPDATE OR DELETE ON users
FOR EACH ROW EXECUTE FUNCTION notify_table_change();

你可以给所有需要监控的表都添加类似的触发器。

步骤2：编写Django自定义命令监听通知 #

在Django项目中创建一个自定义管理命令，用来持续监听PostgreSQL的通知频道：

# 在你的app下创建 management/commands/listen_changes.py
from django.core.management.base import BaseCommand
import psycopg2
from django.db import connections
from django.dispatch import Signal

# 定义一个自定义信号，方便其他模块接收变更通知
table_changed = Signal(providing_args=["table_name", "operation"])

class Command(BaseCommand):
    help = '持续监听PostgreSQL表变更通知'

    def handle(self, *args, **options):
        # 获取Django的数据库连接
        conn = connections['default'].connection
        # 必须设置自动提交，否则无法接收通知
        conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)
        cur = conn.cursor()
        
        # 订阅目标频道
        cur.execute("LISTEN table_change_channel;")
        self.stdout.write(self.style.SUCCESS('已开始监听数据库表变更...'))

        try:
            while True:
                # 轮询获取通知
                conn.poll()
                while conn.notifies:
                    notify = conn.notifies.pop(0)
                    table_name, operation = notify.payload.split(':')
                    self.stdout.write(f"收到变更通知：表 {table_name} 执行了 {operation} 操作")
                    
                    # 发送Django信号，让其他业务逻辑响应变更
                    table_changed.send(sender=self, table_name=table_name, operation=operation)
        except KeyboardInterrupt:
            self.stdout.write(self.style.WARNING('监听已停止'))
            cur.close()

这样，你就可以在其他Django模块中监听table_changed信号，执行对应的业务逻辑（比如更新缓存、同步数据等）。

运行与管理 #

执行命令启动监听：

python manage.py listen_changes

为了让这个进程持续运行，你可以请求服务器管理员用systemd或supervisor来托管这个进程（这比cron更合规，因为它是常驻服务，而非定时任务）。

优缺点 #

• ✅ 实时性强，表变更后立即触发通知
• ✅ 完全依赖原生功能，无需额外插件
• ❌ 需要常驻进程，需要服务器管理员配合配置进程管理

方案2：变更日志表 + Django触发式检查（非实时但无需常驻进程） #

如果无法配置常驻进程，这个方案可以通过被动检查来感知变更，适合对实时性要求不高的场景。

步骤1：创建变更日志表并更新触发器 #

首先创建一个专门记录表变更时间的日志表：

CREATE TABLE table_change_log (
    table_name VARCHAR(255) PRIMARY KEY,
    last_changed TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);

然后修改之前的触发器函数，在发送通知的同时更新日志表：

CREATE OR REPLACE FUNCTION notify_table_change()
RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify('table_change_channel', TG_TABLE_NAME || ':' || TG_OP);
    -- 更新或插入变更记录
    INSERT INTO table_change_log (table_name, last_changed)
    VALUES (TG_TABLE_NAME, CURRENT_TIMESTAMP)
    ON CONFLICT (table_name) DO UPDATE SET last_changed = CURRENT_TIMESTAMP;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

步骤2：在Django中实现触发式检查 #

你可以在Django的视图、中间件或者任务中，对比缓存的最后变更时间和日志表中的时间：

from django.core.cache import cache
from django.db import connection

def check_table_changes(table_name):
    cache_key = f"table_last_changed:{table_name}"
    cached_time = cache.get(cache_key)
    
    # 从日志表获取最新变更时间
    with connection.cursor() as cur:
        cur.execute("SELECT last_changed FROM table_change_log WHERE table_name = %s", [table_name])
        result = cur.fetchone()
        if not result:
            return False
        db_time = result[0].isoformat()
    
    if cached_time != db_time:
        # 表发生了变更，执行你的业务逻辑
        cache.set(cache_key, db_time)
        return True
    return False

比如在视图中调用这个函数，或者在中间件中对关键表做全局检查，这样每次请求时都会被动感知变更。

优缺点 #

• ✅ 无需常驻进程，依赖Django现有请求流程
• ✅ 实现简单，无需额外配置
• ❌ 非实时，只有在有请求时才会检查变更

方案3：PostgreSQL日志解析（需日志访问权限） #

如果数据库管理员允许你读取PostgreSQL的日志文件，你可以通过实时解析日志来感知表变更。

实现思路 #

1. 确保PostgreSQL的日志配置中记录了所有DML操作（log_statement = 'mod'）
2. 用Python脚本（比如结合watchdog库）实时监控日志文件的新增内容
3. 解析日志中的INSERT/UPDATE/DELETE语句，提取表名，然后触发Django的业务逻辑

这个方案的缺点是日志解析可能存在误判，且依赖日志配置和访问权限，但也是一个可行的备选方案。

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