如何在AWS Lambda中使用Nest.js SSE？

要在AWS Lambda中使用Nest.js SSE（ Server -Sent Events），您需要使用Nest.js SSE库来处理SSE连接。以下是在AWS Lambda中使用Nest.js SSE的解决方法的代码示例：

npm install @nestjs/platform-express @nestjs/sse
创建一个Nest.js应用程序，并配置它以在AWS Lambda中运行：
import { NestFactory } from '@nestjs/core';
import { ExpressAdapter } from '@nestjs/platform-express';
import { AppModule } from './app.module';
import * as express from 'express';
async function bootstrap() {
  const expressApp = express();
  const app = await NestFactory.create(
    AppModule,
    new ExpressAdapter(expressApp),
  await app.init();
  return expressApp;
export const handler = async (event: any, context: any) => {
  const expressApp = await bootstrap();
  return expressApp(event, context);
创建一个SSE控制器：
import { Controller, Get, Res } from '@nestjs/common';
import { Sse } from '@nestjs/sse';
@Controller('sse')
export class SseController {
  constructor(private readonly sse: Sse) {}
  @Get()
  async stream(@Res() res: any) {
    res.sseSetup();
    this.sse.init(res);
    const data = { message: 'Hello from SSE' };
    setInterval(() => {
      this.sse.send(data);
    }, 1000);
创建一个Nest.js模块并将SSE控制器添加到其中：
import { Module } from '@nestjs/common';
import { SseModule } from '@nestjs/sse';
import { SseController } from './sse.controller';
@Module({
  imports: [SseModule],
  controllers: [SseController],
export class AppModule {}
使用AWS SAM（Serverless Application Model）部署您的Lambda函数。在AWS SAM模板文件（template.yaml）中定义您的Lambda函数：
Resources:
  YourLambdaFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: .
      Handler: dist/handler.handler
      Runtime: nodejs14.x
      Events:
        ApiEvent:
          Type: Api
          Properties:
            Path: /sse
            Method: get
部署Lambda函数：
sam deploy --guided
现在，您可以通过使用生成的API网关URL访问SSE端点来测试Lambda函数。每秒钟，它将发送一个包含“Hello from SSE”消息的SSE事件到客户端。
请注意，这只是一个简单的示例，用于说明如何在AWS Lambda中使用Nest.js SSE。您可能需要根据自己的需求进行调整和扩展。