Unterstützung mehrerer Trigger für AWS Lambda in Golang

Einführung

AWS Lambda unterstützt Triggerfunktionen aus verschiedenen Quellen, einschließlich S3-Ereignissen und SQS-Nachrichten. Wenn Ihre Lambda-Funktion jedoch auf mehrere Auslöser reagieren muss, entsteht ein Dilemma.

Vorgeschlagene Lösungen

Sie haben zwei Ansätze versucht:

Erster Ansatz:

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

Diese Methode ist fehlgeschlagen, weil der erste Trigger (ProcessIncomingS3Events) immer alle Ereignisse verarbeiten würde.

Zweiter Ansatz:

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

In diesem Szenario konnte Lambda den Ereignistyp nicht identifizieren, was zu Fehlern „Der Ereignistyp konnte nicht gefunden werden“ für alle Trigger führte.

Multi-Event-Handler-Implementierung

Um diese Einschränkungen zu überwinden, können Sie mithilfe der AWS-Handler-Schnittstelle einen Multi-Event-Handler implementieren. Hier ist eine Beispielimplementierung:

type Handler struct {
    // Define global variables or context information
}

func (h Handler) Invoke(ctx context.Context, data []byte) ([]byte, error) {
    // Unmarshal the data based on different event types

    var apiGatewayEvent events.APIGatewayProxyRequest
    if err := json.Unmarshal(data, &apiGatewayEvent); err == nil {
        // Handle API Gateway event
    }

    var snsEvent events.SNSEvent
    if err := json.Unmarshal(data, &snsEvent); err == nil {
        // Handle SNS event
    }

    return nil, nil
}

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

Mit diesem Ansatz kann Ihre Lambda-Funktion verschiedene AWS-Ereignisse abhören und entsprechend behandeln.

Überlegungen

Auch wenn die Verwendung dieser Methode Flexibilität bietet, denken Sie daran, dass Lambda-Funktionen dies tun Entwickelt, um eine einzelne Art von Ereignis effektiv zu bewältigen. Das Mischen mehrerer Ereignistypen kann zu Komplexität und Leistungsproblemen führen.