使用PostgreSQL的Django应用出现connection already closed问题求助

针对你遇到的每30秒执行一次的后台插入任务间歇性报连接已关闭问题，结合你的环境（Django 4.2.13 + psycopg2 2.9.9），可尝试以下针对性方案：

1. 任务执行前强制清理无效连接 #

后台任务复用连接池中的旧连接时，该连接可能已被数据库端主动回收。在任务开始前调用close_old_connections()，强制关闭所有过期或无效连接，确保后续操作使用新连接：

from django.db import close_old_connections

def periodic_insert_task():
    close_old_connections()  # 清理无效连接
    # 执行你的数据库插入逻辑
    YourModel.objects.create(...)
    # 可选：任务结束后再次清理，避免连接池残留无效连接
    close_old_connections()

2. 检查PostgreSQL的连接回收参数 #

确认PostgreSQL端的连接超时设置是否会提前回收空闲连接，重点检查以下两个参数：

• idle_session_timeout：空闲连接（未在事务中）的超时时间
• idle_in_transaction_session_timeout：事务中空闲连接的超时时间

执行SQL查看当前设置：

SHOW idle_session_timeout;
SHOW idle_in_transaction_session_timeout;

如果设置值小于任务周期（30秒），会导致连接被提前回收。调整为大于30秒的值，例如：

ALTER SYSTEM SET idle_session_timeout = '60s';
SELECT pg_reload_conf();

3. 适配异步上下文的连接管理 #

报错栈中出现django\utils\asyncio.py，说明任务可能运行在异步环境中。同步数据库操作在异步上下文易出现连接管理问题，可通过以下方式处理：

• 显式确保连接有效：

from django.db import connection

def periodic_insert_task():
    connection.ensure_connection()  # 确保连接已建立且有效
    # 执行插入操作

• 如果使用异步任务框架（如Celery），确保任务以同步模式运行，避免异步线程与同步连接池冲突。

4. 禁用连接复用（极端方案） #

若以上方案无效，可将CONN_MAX_AGE设为0，强制每次任务都创建新连接（会牺牲少量性能，但彻底避免连接过期问题）：

# settings.py
DATABASES = {
    'default': {
        # 其他数据库配置
        'ENGINE': 'django.db.backends.postgresql',
        'NAME': 'your_db',
        'USER': 'your_user',
        # ...
        'CONN_MAX_AGE': 0,
        'CONN_HEALTH_CHECKS': True,
    }
}

5. 主动检查并重建连接 #

在任务中添加连接状态检查，若连接已关闭则主动重建：

from django.db import connection
import psycopg2

def periodic_insert_task():
    try:
        # 执行简单查询验证连接有效性
        with connection.cursor() as cursor:
            cursor.execute("SELECT 1")
    except psycopg2.InterfaceError:
        # 连接已关闭，重新建立连接
        connection.connect()
    # 执行插入逻辑

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