NestJS TypeORM在AWS Lambda抛AlreadyHasActiveConnectionError异常

项目中使用@nestjs/typeorm连接PostgreSQL数据库，核心配置如下：

@Module({
  imports: [
    ConfigModule.forRoot({
      isGlobal: true,
      validationSchema: envValidator,
      envFilePath: '.env',
    }),
    TypeOrmModule.forRootAsync({
      imports: [ConfigModule],
      inject: [ConfigService],
      useFactory: (configService: ConfigService) => ({
        type: 'postgres',
        host: configService.get<string>('DB_HOST'),
        port: configService.get<number>('DB_PORT'),
        username: configService.get<string>('DB_USER'),
        password: configService.get<string>('DB_PASS'),
        database: configService.get<string>('DB_NAME'),
        synchronize: configService.get<boolean>('DB_SYNC'),
        autoLoadEntities: true,
        logging: configService.get<string>('NODE_ENV') === 'development',
        keepConnectionAlive: true,
      }),
    }),
  ],
})
export class AppModule {}

应用以无服务Lambda形式部署在AWS上运行，请求任意路由时偶发抛出如下错误：

AlreadyHasActiveConnectionError: Cannot create a new connection named "default", because connection with such name already exist and it now has an active connection session.

• AWS Lambda 存在热实例复用机制：短时间内多次触发函数时，Lambda不会每次都重新初始化完整执行环境，会保留上一次调用结束后的进程上下文、全局变量、已建立的连接等资源，减少冷启动耗时。
• 当前TypeORM配置缺少连接存在性校验：每次Lambda触发执行NestJS启动流程时，TypeOrmModule.forRootAsync默认都会尝试创建名为default的新数据库连接。如果请求命中热复用实例，上一次调用残留的default连接还处于活跃状态，就会抛出已存在活跃连接的错误。
• 配置中的keepConnectionAlive: true会主动阻止连接在单次请求结束后被销毁，进一步提升了热实例复用时残留活跃连接的概率。

• 修改TypeORM初始化逻辑，优先复用已存在的活跃连接，避免重复创建
  调整forRootAsync的工厂函数，初始化新连接前先检查是否已存在同名活跃连接，存在则直接返回现有实例，同时关闭不必要的keepConnectionAlive配置：

  import { getConnectionManager } from 'typeorm';
  
  // 其余配置不变，仅修改useFactory逻辑
  useFactory: (configService: ConfigService) => {
    const connectionManager = getConnectionManager();
    // 检查是否已存在default连接
    if (connectionManager.has('default')) {
      const existedConnection = connectionManager.get('default');
      // 连接处于活跃状态直接复用，不需要新建
      if (existedConnection.isConnected) return existedConnection;
    }
  
    return {
      type: 'postgres',
      host: configService.get<string>('DB_HOST'),
      port: configService.get<number>('DB_PORT'),
      username: configService.get<string>('DB_USER'),
      password: configService.get<string>('DB_PASS'),
      database: configService.get<string>('DB_NAME'),
      synchronize: configService.get<boolean>('DB_SYNC'),
      autoLoadEntities: true,
      logging: configService.get<string>('NODE_ENV') === 'development',
      keepConnectionAlive: false, // 关闭强制保活，适配Lambda复用逻辑
      // 适配Lambda单实例单请求模型，限制连接池大小
      extra: {
        max: 1,
        connectionTimeoutMillis: 10000,
      },
    }
  }
  

• 调整Lambda执行上下文配置，避免事件循环阻塞
  在Lambda入口handler处将callbackWaitsForEmptyEventLoop设为false，阻止数据库连接等后台任务阻塞Lambda执行流程结束，配合连接复用逻辑降低异常概率：

  import { NestFactory } from '@nestjs/core';
  import { AppModule } from './app.module';
  
  export const handler = async (event: any, context: any) => {
    // 不等待事件循环清空就返回响应，适配无服务执行模型
    context.callbackWaitsForEmptyEventLoop = false;
    
    const app = await NestFactory.create(AppModule);
    await app.init();
    // 原有请求处理、路由转发逻辑保持不变
    const response = await app.getHttpAdapter().getInstance()(event, context);
    return response;
  };
  

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