Django应用内定期轮询数据库遭遇权限错误问题求助

你的问题本质不是数据库用户真的没有权限（HTTP请求中能正常操作数据库已经证明权限配置正确），而是自定义线程没有触发Django的数据库连接管理机制，导致连接参数未正确加载，进而抛出权限类错误。以下是针对线程方案的修复步骤：

核心问题分析 #

Django在HTTP请求生命周期内会自动管理数据库连接（请求开始时初始化连接、结束时回收），但自定义线程不会触发这个流程，直接调用ORM会导致连接未正确初始化，无法读取settings.py中通过环境变量配置的数据库账号信息。

修复后的线程代码 #

import threading
import logging
import time
from datetime import datetime, timedelta, timezone
from django.db import connection
from . import models
from . import socket_views

class WatchCheckIn(threading.Thread):
    def run(self) -> None:
        logging.info('Check-in watcher thread started.')
        # 无限循环实现持续轮询
        while True:
            try:
                # 手动确保数据库连接有效，自动读取settings中的环境变量配置
                connection.ensure_connection()
                logging.info('Querying database for check-ins.')
                
                latest_record = models.CheckIn.objects.last()
                check_in_period = datetime.now(timezone.utc) - timedelta(minutes=10)
                
                if not latest_record:
                    logging.warning('No previous check-ins found.')
                elif latest_record.check_in_time < check_in_period:
                    socket_views.notify_need_check_in()
                    
            except Exception as e:
                logging.error(f'Error checking check-ins: {str(e)}')
            finally:
                # 手动关闭连接，避免连接池泄漏
                connection.close()
                time.sleep(600)

额外优化：避免线程重复启动 #

Django在runserver自动重载或某些部署场景下会多次调用AppConfig.ready()，导致线程被重复创建。修改apps.py添加启动标志：

from django.apps import AppConfig
import threading

class YourAppConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'your_app_name'
    _thread_started = False

    def ready(self):
        if not self._thread_started:
            from .watch_thread import WatchCheckIn
            WatchCheckIn().start()
            self._thread_started = True

关键修复点说明 #

1. 添加无限循环：原代码只执行一次查询就结束线程，while True才能实现持续轮询
2. 手动管理数据库连接：
   • connection.ensure_connection()：检查当前线程是否有活跃连接，无则根据settings.py配置创建（自动读取K8s环境变量中的账号密码）
   • connection.close()：操作完成后关闭连接，避免连接池资源泄漏
3. 修正异常处理：原代码仅捕获IndexError，但objects.last()返回None时访问属性会抛出AttributeError，改用通用异常捕获+前置判空覆盖所有场景

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