Heroku服务器上Django项目的Heroku Postgres无法写入数据

一、配置有效性验证 #

1. 数据库配置 #

• 执行 heroku config:get DATABASE_URL 确认环境变量存在且格式正确（应为postgres://user:pass@host:port/dbname）。
• 优化settings.py的数据库配置，避免空默认值干扰环境变量覆盖：

  DATABASES = {
      'default': dj_database_url.config(conn_max_age=600)
  }
  

  原配置中的空NAME/USER等字段可能导致update逻辑未完全覆盖。

2. Celery进程环境变量 #

• 查看Worker日志：heroku logs --ps worker，搜索是否有psycopg2连接错误（比如无法解析主机、权限不足）。
• 确认Worker进程能读取到DATABASE_URL：在任务中加入日志输出数据库配置，或者执行heroku run:worker python -c "import os; print(os.getenv('DATABASE_URL'))"验证。

二、任务逻辑排查 #

1. Django环境初始化 #

Celery Worker是独立进程，必须确保任务加载了Django配置：

• 检查项目根目录的celery.py（如果没有则创建）是否包含：

  import os
  from celery import Celery
  
  os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'Soccer.settings')
  app = Celery('Soccer')
  app.config_from_object('django.conf:settings', namespace='CELERY')
  app.autodiscover_tasks()
  

• 如果任务未通过自动发现加载，需在任务开头手动初始化Django：

  import django
  from django.conf import settings
  
  if not settings.configured:
      django.setup()
  

2. 异常日志排查 #

任务中若有未捕获的异常，会导致静默失败，需添加日志：

import logging
logger = logging.getLogger(__name__)

def add_data_util():
    try:
        # 你的数据写入逻辑
        logger.info("数据写入操作执行完成")
    except Exception as e:
        logger.error(f"数据写入失败: {str(e)}", exc_info=True)

查看Worker日志中的错误信息，定位具体问题（比如字段不匹配、权限不足）。

三、Heroku服务状态检查 #

1. 进程状态 #

执行 heroku ps，确认worker和beat进程处于up状态。若进程崩溃，查看崩溃日志：heroku logs --ps worker --tail。

2. Redis服务验证 #

• 执行 heroku addons 确认已安装Redis插件（如Heroku Redis），且REDIS_URL环境变量存在。
• 测试Redis连接：heroku run python -c "import redis; import os; r = redis.from_url(os.getenv('REDIS_URL')); print(r.ping())"，确保Broker正常工作。

3. Postgres连接限制 #

Heroku Postgres有连接数配额，Worker进程过多可能导致连接耗尽：

• 在settings.py中添加连接池配置：

  DATABASES['default']['OPTIONS'] = {
      'pool_size': 5,
      'max_overflow': 10,
  }
  

• 减少Worker进程数：在Procfile中指定worker: celery -A Soccer worker --loglevel=info --concurrency=2，避免并发过高。

四、快速验证方法 #

直接在Heroku上手动执行任务，排除Celery Broker的影响：

heroku run python manage.py shell

在Shell中调用任务：

from comparasion.tasks import add_data_util
add_data_util()

观察是否有报错，直接验证任务与数据库的交互逻辑。

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