Функция Spring Cloud и запускаемая SQSEvent лямбда-функция AWS - PullRequest
0 голосов
/ 27 мая 2019

Мне не удается заставить работать лямбда-функцию AWS на основе Spring Cloud с триггером SQS Message.Я использую адаптер AWS Spring Cloud Function версии 2.0.1.RELEASE и пытаюсь выполнить развертывание в регионе AWS EU-WEST-2.

Мой SpringBootRequestHandler определяется следующим образом:

    import org.springframework.cloud.function.adapter.aws.SpringBootRequestHandler;

    import com.amazonaws.services.lambda.runtime.events.SQSEvent;
    public class ReplicationHandler extends SpringBootRequestHandler<SQSEvent, String>{

}

Моя функция @Bean выглядит следующим образом:

    @Bean
    public Function<SQSEvent, String> handleEvent() {   
        return value -> processEvent((SQSEvent)value);
    }

Я передаю это со следующим тестовым событием:

{
  "Records": [
    {
      "messageId": "02a4e04b-a1d2-417a-b073-56123be35ac6",
      "receiptHandle": "AQEB0fsSc76vU9Y6vQEz",
      "body": "hello world",
      "attributes": {
        "ApproximateReceiveCount": "1",
        "SentTimestamp": "1553860061037",
        "SenderId": "AIDAIVEA3AGEU7NF6DRAG",
        "ApproximateFirstReceiveTimestamp": "1553860061042"
      },
      "messageAttributes": {},
      "md5OfBody": "a4d19d8b1019e01bb875eea6232bf2f1",
      "eventSource": "aws:sqs",
      "eventSourceARN": "arn:aws:sqs:eu-west-2:XXXXX:YYYYY",
      "awsRegion": "eu-west-2"
    }
  ]
}


Когда я запускаю это, я получаю следующую ошибку:

{
  "errorMessage": "reactor.core.publisher.FluxJust cannot be cast to com.amazonaws.services.lambda.runtime.events.SQSEvent",
  "errorType": "java.lang.ClassCastException",
  "stackTrace": [
    "org.springframework.cloud.function.adapter.aws.SpringFunctionInitializer.apply(SpringFunctionInitializer.java:132)",
    "org.springframework.cloud.function.adapter.aws.SpringBootRequestHandler.handleRequest(SpringBootRequestHandler.java:48)"
  ]
}

У кого-нибудь есть предложения по поводу того, что здесь происходит?В качестве альтернативы, если есть какие-либо рабочие примеры в Интернете для моего точного сценария, это также было бы хорошо.

...