SAM 模板 - 将 SQS 项发送到现有 Java 服务

Question

我们目前有 要求：

APIEndPoint ---> aws Lambda ------>aws SQS -----> Java_service

其中 APIEndPoint、Lambda 和 AWS_SQS 是需要与现有 Java_service连接的无服务器功能（新） >（不是无服务器功能）。

Lambda 是一个 NodeJS 运行时

SQS 名称是MyQueue(say)

---

而不是Java_service（上），如果是另一个NodeJS lambda函数（比如sqsHandler），比如：

APIendPoint ---> aws Lambda ------>aws SQS -----> aws Lambda 2

那么模板将是：

functions:
   sqsHandlFunc:
     handler: handler.sqsHandler
     events:
       - sqs:
          arn:
             Fn:GetAtt:
                 - MyQueue
                 - Arn
             batchSize: 1

---

如果处理程序 (sqsHandlFunc) 将 awsSQS 连接到 java 服务（非无服务器），SAM 模板连接应该是什么？ java service(springboot app) 可通过 REST api 获得

Answer 1

您将无法通过 SAM 模板进行设置。您需要让 Java 服务使用 AWS Java SDK for SQS 轮询 SQS 队列，特别是 receiveMessage (see the receiveMessage section in this example)