amazon-web-services - 如何在 Golang 的 AWS Lambda 中支持多个触发器？

Question

我正在 Golang 中构建一个 AWS Lambda 函数，用于将内容从 n 个 S3 存储桶复制到 m 个 S3 存储桶。需要支持 S3 触发器以及从存储所有源 S3 存储桶更改的 SQS 中获取数据。代码可以在这里找到:https://github.com/maknahar/s3copy

我试过以下:

func main() {
    lambda.Start(ProcessIncomingS3Events)
    lambda.Start(ProcessIncomingEvents)
}

func ProcessIncomingS3Events(event events.S3Event) error {
    ...
    log.Println("Got S3 Event")
    return processS3Trigger(config, event)
}

func ProcessIncomingEvents() error {
    ...
    log.Println("Defaulting to SQS")
    return processSQSMessage(config)
}

在这种情况下，每次都会触发第一个事件 ProcessIncomingS3Events。

我也试过关注

func main() {
    lambda.Start(ProcessIncomingEvents)
}

func ProcessIncomingEvents(event interface{}) error {
    ...
    switch request := event.(type) {
    case events.S3Event:
        log.Println("Got S3 Event")
        return processS3Trigger(config, request)

    case types.Nil:
        log.Println("Defaulting to SQS")
        return processSQSMessage(config)

    default:
        log.Println("Could not find the event type")

    }

    return nil
}

在这种情况下，Lambda 无法检测到类型，并且 Could not find the event type 会记录在每个触发器中。

有没有办法通过 AWS SDK 完全支持函数的多个触发器？

Answer 1

我通过实现aws Handler接口(interface)实现了监听多个事件，它定义了一个方法

Invoke(ctx context.Context, payload []byte) ([]byte, error)

我实现了一个多事件处理程序如下

type Handler struct {
//add global variables or context information that your handler may need
}

func (h Handler) Invoke(ctx context.Context, data []byte) ([]byte, error) {
  //for demonstration purposes, not the best way to handle
  apiGatewayEvent := new(events.APIGatewayProxyRequest)
  if err := json.Unmarshal(data, apiGatewayEvent); err != nil {
    log.Println("Not a api gateway event")
  }
  snsEvent := new(events.SNSEvent)
  if err := json.Unmarshal(data, snsEvent); err != nil {
    log.Println("Not a sns event")
  }
  return nil, nil
}

func main() {
  lambda.StartHandler(Handler{})
}

如您所见，您可以获得任何事件的原始字节并根据需要处理它们，从而使您有可能使用相同的 lambda 监听任何 aws 事件。但是，在使用这种方法之前请仔细考虑，因为如上所述，lambda 最好只用于处理一种类型的事件

希望这对您有所帮助。