时间戳

首页 > 解决方案 > NestJs Eventbridge Lambda 函数

node.js - NestJs Eventbridge Lambda 函数

问题描述

我有一个使用 NestJs 和无服务器框架编写的系统，每个端点都是 aws 上的 lambda 函数。其中一个功能不是端点，而是来自 AWS eventbridge 的触发器。由于此函数不是端点，因此它不能包含在 NestJs 模块中，因为它必须单独导出。我的问题是，当事件到达 Eventbridge 并触发 lambda 时，我必须调用 NestJs 服务，但我无法做到这一点，因为 lambda 函数位于 NestJs 环境之外。这是我从模块外部调用 NestJs 服务的一种方式吗？

这是无服务器框架配置

functions:
  function 1(NestJs controller):
    handler: src/lambda.handler
    events:
      - http:
          cors: true
          method: post
          path: entrypoint for function 1
  Function 2 (External from NestJs modules):
    handler: path to lambda function
    events:
      - eventBridge:
          eventBus: eventbus name
          pattern:
            source:
              - source

目前我正在使用 axios 调用另一个 NestJs 端点来传递接收到的有效负载。正如您在 lambda 函数文件中看到的：

import { Context, Handler } from 'aws-lambda'
import axios from 'axios'
export const handler: Handler = async (event: any, context: Context) => {
  return await axios
    .post(
      'lambda function production url',
      event.detail
    )
    .then((data) => {
      console.log('data', data)
      return data
    })
    .catch((error) => {
      console.log('error', error)
      return error
    })
}

这是 lambda 函数 1 的控制器

import { Body, Controller, Post } from '@nestjs/common'
import { MyService } from './enrichment.service'

@Controller('function1')
export class EnrichmentController {
  constructor(private readonly myService: MyService) {}
  @Post('entrypoint')
  sendForm(@Body() body) {
    return this.myService.start(body)
  }
}

这是服务

import { forwardRef, Inject, Injectable } from '@nestjs/common'
import { EventbridgeService } from '../eventbridge/eventbridge.service'
import { CampaignsService } from '../campaigns/campaigns.service'
import { UploadedDataService } from '../uploaded-data/uploaded-data.service'

@Injectable()
export class MyService {
  constructor(
    private readonly anotherService: AnotherService,
  ) {}
  async start(body) {
    return this.anotherService.updateData(body)
  }
}

问题是：这是一种从函数文件中调用所有 NestJs 结构的方法吗，因为它在 NestJs 模块之外，并且因为该函数的触发器不是 http 请求而是来自 Eventbridge 的触发器？太感谢了。

标签： node.jsmicroservicesnestjsserverless-frameworkaws-event-bridge

解决方案

您可以使用“独立”Nest 应用程序并将事件数据直接传递给MyService

推荐阅读