Лямбда с событием sqs не повторяется в случае сценария RuntimeException - PullRequest
0 голосов
/ 23 октября 2019

Я пытаюсь, чтобы лямбда-обработчик автоматически повторял попытки в случае сценария исключения. Эта лямбда будет запущена по запросу SQS. Ниже приведен мой фрагмент кода. Подобный лямбда-сигнал на триггере событий S3 put может обрабатывать сценарии исключений и может повторить попытку самостоятельно, но не может сделать это для триггеров sqs. Есть ли различия между этими двумя типами лямбда-триггеров? Лямбда по-разному обрабатывает триггеры разных типов?

 @Override
  public String handleRequest(SQSEvent event, Context context) {
    AtomicReference<String> resultResponse = new AtomicReference<>();
    event.getRecords().forEach(sqsRecord -> {
      //some business logic....
      throw new ProvisionedThroughputExceededException("");
      // some busines logic ...
    });
    return resultResponse.get();
  }
...