Rails中ActiveRecord::ConnectionNotEstablished错误排查求助

针对你遇到的主从数据库配置中，Sidekiq/good_job触发No connection pool for 'ActiveRecord::Base' found的问题，以下是具体排查方向：

1. 确保多角色连接池完成初始化 #

主从库配置下，Rails需要为primary（写）和primary_replica（读）分别创建连接池。Sidekiq启动时可能未完整加载所有角色的连接配置，导致首次任务执行时连接池不存在：

• 在config/initializers/sidekiq.rb中添加启动钩子，强制初始化所有角色的连接池：

  Sidekiq.configure_server do |config|
    config.on(:startup) do
      # 初始化主库连接池
      ActiveRecord::Base.establish_connection
      # 初始化从库连接池
      ActiveRecord::Base.establish_connection(:primary_replica)
    end
  end
  

• 执行ActiveRecord::Base.connection_handler.connection_pools验证，确认存在:primary和:primary_replica对应的连接池。

2. 检查连接池角色配置有效性 #

验证database.yml的replica配置是否被Rails正确识别：

• 在控制台执行ActiveRecord::Base.configurations，查看development环境下的primary_replica配置是否包含replica: true，且角色被标记为:reading。
• 如果未识别到replica角色，检查配置格式是否有误（比如缩进、引用是否正确）。

3. 调整Sidekiq线程的连接初始化时机 #

Sidekiq多线程启动时，可能因连接池未就绪导致首次任务报错，可通过以下方式优化：

• 在任务的perform方法中手动绑定连接池：

  def perform(*args)
    ActiveRecord::Base.connection_pool.with_connection do
      # 任务业务逻辑
    end
  end
  

• 在Sidekiq配置中强制预加载Rails环境和连接池：

  Sidekiq.configure_server do |config|
    config.redis = { url: ENV['REDIS_URL'] }
    Rails.application.eager_load!
    # 重置并重新建立连接池
    ActiveRecord::Base.connection_pool.disconnect!
    ActiveRecord::Base.establish_connection
  end
  

4. 排查连接池的异常操作 #

检查是否有代码干扰了连接池的正常运作：

• 确认任务中没有手动关闭连接的代码（如ActiveRecord::Base.connection.close），避免导致连接池资源被意外释放。
• 计算总连接数是否超过PostgreSQL限制：Puma线程数(5) + Sidekiq并发数(5) 乘以每个进程的连接池大小(20)，总连接数为40，远低于PostgreSQL默认的100连接上限，此问题概率较低，但可通过show max_connections;在PostgreSQL中确认。

5. 测试主从库切换逻辑 #

编写测试任务验证主从连接是否正常：

class TestReplicaConnectionJob < ApplicationJob
  queue_as :default

  def perform
    # 主库写操作
    User.create!(name: 'test_connection')
    # 从库读操作
    ActiveRecord::Base.connected_to(role: :reading) do
      puts "从库读取用户数：#{User.count}"
    end
  end
end

执行该任务，若首次报错重试正常，说明连接池为延迟初始化，需通过启动钩子提前完成所有角色的连接池建立。

6. 排查Gem冲突或初始化顺序问题 #

暂时禁用非核心Gem（如自定义初始化脚本、第三方业务Gem），逐步恢复排查是否有Gem在Rails初始化完成前触发数据库连接，导致连接池未正确建立。

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