如何在NestJS Lambda函数中处理数据库连接模块加载异常？

核心问题分析 #

模块加载阶段（比如Mongoose连接初始化）发生在NestFactory.create()调用过程中，此时全局异常过滤器尚未注册，因此无法捕获该阶段的错误。而Lambda会因为应用未正常启动但进程未终止，最终超时返回504错误。

解决方案 #

1. 在Bootstrap流程中捕获初始化异常 #

将NestFactory.create()及后续初始化逻辑包裹在try/catch中，直接捕获模块加载时的错误，避免错误扩散导致Lambda超时。

修改后的bootstrap函数：

async function bootstrap(): Promise<Handler> {
  try {
    const app = await NestFactory.create(ApiModule, { bufferLogs: true });

    app.useLogger(app.get(Logger));
    app.flushLogs();

    const httpAdapter = app.get(HttpAdapterHost);
    app.useGlobalFilters(new AllExceptionsFilter(httpAdapter));

    await app.init();

    const appConfig: AppConfigService = app.get(AppConfigService);
    app.setGlobalPrefix(appConfig.STAGE);

    const expressApp = app.getHttpAdapter().getInstance();
    return serverlessExpress({ app: expressApp });
  } catch (error) {
    console.error('应用初始化失败:', error);
    throw error; // 抛出错误让handler层处理
  }
}

2. 在Lambda Handler中直接返回错误响应 #

当bootstrap失败时，不再等待进程超时，而是直接构造错误响应返回给调用方，快速终止Lambda执行。

修改后的handler函数：

export const handler: Handler = async (event: unknown, context: Context, callback: Callback) => {
  try {
    server = server ?? (await bootstrap());
    return server(event, context, callback);
  } catch (error) {
    const errorMsg = error instanceof Error ? error.message : '未知初始化错误';
    const errorResponse = {
      statusCode: 500,
      body: JSON.stringify({
        message: '服务初始化失败',
        error: errorMsg
      })
    };
    callback(null, errorResponse);
  }
};

3. 增强Mongoose模块的连接错误处理 #

在MongooseModule.forRootAsync的useFactory中手动测试数据库连接，确保连接失败时立即抛出明确异常，提前终止初始化流程。

修改后的数据库模块：

import mongoose from 'mongoose';
import { InternalServerErrorException } from '@nestjs/common';

@Module({
    imports: [
        MongooseModule.forRootAsync({
            imports: [MongoConfigModule],
            useFactory: async (config: MongoConfigService) => {
                const mongooseConfig = {
                    uri: config.URI,
                    // ... 其他MongoDB配置
                };
                try {
                    // 手动发起连接，捕获连接错误
                    await mongoose.connect(mongooseConfig.uri, mongooseConfig);
                } catch (dbError) {
                    console.error('MongoDB连接失败:', dbError);
                    throw new InternalServerErrorException('数据库连接失败');
                }
                return mongooseConfig;
            },
            inject: [MongoConfigService],
        }),
    ],
    providers: [],
})
export class MongoDatabaseProviderModule {}

为什么全局过滤器无法处理该场景？ #

全局异常过滤器是在应用初始化完成后注册的，而模块加载（包括数据库连接）是NestFactory.create()的核心执行步骤，此时过滤器还未生效，因此无法捕获这个阶段的错误。必须在初始化流程的最外层（bootstrap和handler）进行异常捕获。

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