aws lambda in golang, ausgelöst durch sqs mit Typfehler

php-Editor Baicao bringt Ihnen dieses Mal Fragen zu AWS Lambda in Golang. Beim Auslösen einer Lambda-Funktion mithilfe von AWS SQS kann ein Typfehler auftreten. Dieses Problem kann dazu führen, dass die Lambda-Funktion SQS-Nachrichten nicht normal verarbeiten kann, was den Entwicklern unnötige Probleme bereitet. In diesem Artikel werden wir die Ursachen dieses Problems untersuchen und Lösungen bereitstellen, die Entwicklern helfen, dieses Fehlerdilemma erfolgreich zu lösen.

Frageninhalt

Ich entwickle ein Lambda, das durch API-Gateway und SQL ausgelöst wird.

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/aws/aws-lambda-go/events"
    "github.com/aws/aws-lambda-go/lambda"

    regcode "company/gateway/lambda/regcode/lib"
)

func main() {

    // start the lambda function with both sqs and lambda url handlers
    lambda.start(func(ctx context.context, event interface{}) error {
        fmt.println("event type: ", event)
        switch event.(type) {
        case events.sqsevent:
            return regcode.handlersqs(ctx, event.(events.sqsevent))
        case events.apigatewayproxyrequest:
            response, err := regcode.handlerlambdaurl(ctx, event.(events.apigatewayproxyrequest))
            if err != nil {
                log.println(err)
                return err
            }
            log.printf("api gateway response: %v", response)
            return nil
        default:
            return fmt.errorf("unknown event type: %t", event)
        }
    })
}

Aber mein Switch-Typ erkennt nicht, wann Sqs- oder Apigateway-Ereignisse verwendet werden sollen. Es gehört immer zur Standardanweisung. Für Quadrate verwende ich beispielsweise dieses Ereignis:

{
  "records": [
    {
      "messageid": "19dd0b57-b21e-4ac1-bd88-01bbb068cb78",
      "receipthandle": "messagereceipthandle",
      "body": "hello from sqs!",
      "attributes": {
        "approximatereceivecount": "1",
        "senttimestamp": "1523232000000",
        "senderid": "123456789012",
        "approximatefirstreceivetimestamp": "1523232000001"
      },
      "messageattributes": {},
      "md5ofbody": "{{{md5_of_body}}}",
      "md5ofmessageattributes": "test",
      "eventsource": "aws:sqs",
      "eventsourcearn": "arn:aws:sqs:us-east-1:123456789012:myqueue",
      "awsregion": "us-east-1"
    }
  ]
}

und diese Nachricht erhalten:

unknown event type: map[string]interface {}: errorstring

Irgendeine Idee, was ich falsch gemacht habe? Ich bin neu in der Verwendung von Golang, also bin ich hier verloren.

Außerdem habe ich versucht, das Ereignis direkt an regcode.handlersqs zu senden, aber es ist ein Typkonvertierungsfehler aufgetreten. So:

func main() {

    // Start the Lambda function with both SQS and Lambda URL handlers
    lambda.Start(func(ctx context.Context, event interface{}) error {
        sqsEvent, _ := event.(SQSEvent)
        // ...
    })
}

sqsevent ist leer.

Lösung

Irgendeine Idee, was ich falsch gemacht habe?

AWS-Lambda-Handler spiegeln func 中参数的类型，然后创建与您的签名匹配的 event Typen wider.

Wenn Sie also func 的第二个参数声明为 event events.SQSEvent，AWS 将获取其类型 events.SQSEvent, erstellen Sie ein Objekt wie dieses und übergeben Sie es.

Ähnlich, wenn Sie func 中使用 event events.APIGatewayProxyRequest，AWS 将反映 event 应该是 events.APIGatewayProxyRequest und es erstellen würden.

Mit anderen Worten: AWS prüft nicht, ob die eingehende Anfrage von SQS oder API stammt. Dies wird nur anhand der Unterschrift Ihres Hundeführers festgestellt. Also, wenn du in func 中使用 event 接口{}，AWS 将准确创建您指定要创建的内容，即 interface{} bist und kein anderer Typ.

Aus diesem Grund funktioniert Ihr Schalter nicht. Der einfachste Weg, dieses Problem zu lösen, besteht darin, zwei Lambda-Funktionen zu verwenden, eine für SQS und eine für die API.

Das obige ist der detaillierte Inhalt vonaws lambda in golang, ausgelöst durch sqs mit Typfehler. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!