java - 无法使用 Lambda 中的 SQS

Question

我做了什么:

我正在创建一个示例计划 lambda，它需要从 SQS 队列中取出消息。我使用无服务器框架和 Kotlin 创建了它，配置如下:

service: example

provider:
  name: aws
  runtime: java8
  region: eu-west-1
  memorySize: 128
  environment:
      sqs_url:
        Ref: MessagesQueue
  iamRoleStatements:
      - Effect: Allow
        Action:
          - sqs:*
        Resource:
          Fn::GetAtt: [ MessagesQueue, Arn ]

package:
  artifact: target/example-1.0.0.jar

functions:
  dequeue:
    handler: com.example.Handler
    events:
      - schedule: rate(2 minutes)

resources:
  Resources:
    MessagesQueue:
      Type: AWS::SQS::Queue
      Properties:
        QueueName: ${self:service}-queue

这是处理程序类:

package com.example

import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.lambda.runtime.RequestHandler
import org.slf4j.LoggerFactory
import com.amazonaws.services.sqs.AmazonSQSClientBuilder

class Handler:RequestHandler<Map<String, Any>, Any> {
    override fun handleRequest(input:Map<String, Any>, context:Context):Any {

        LOG.info("Initializing SQS Client...")
        val sqs = AmazonSQSClientBuilder.defaultClient()
        LOG.info("SQS Client Initialized!")

        return Any()
    }
    companion object {
        private val LOG = LoggerFactory.getLogger(Handler::class.java)
    }
}

我在我的 POM 上使用以下 AWS 依赖项:

    <dependency>
        <groupId>com.amazonaws</groupId>
        <artifactId>aws-java-sdk-sqs</artifactId>
        <version>1.11.251</version>
    </dependency>
    <dependency>
        <groupId>com.amazonaws</groupId>
        <artifactId>aws-lambda-java-core</artifactId>
        <version>1.1.0</version>
    </dependency>

我的问题:

我的 lambda 正在记录如下:

START RequestId: ac75e49e-e56e-11e7-ba03-39085056ac2f Version: $LATEST
[2017-12-20 10:15:18.015] ac75e49e-e56e-11e7-ba03-39085056ac2f INFO c.p.Handler - Initializing SQS Client...
END RequestId: ac75e49e-e56e-11e7-ba03-39085056ac2f
REPORT RequestId: ac75e49e-e56e-11e7-ba03-39085056ac2f  Duration: 6006.13 ms  Billed Duration: 6000 ms Memory Size: 128 MB  Max Memory Used: 60 MB  
2017-12-20T10:15:23.185Z ac75e49e-e56e-11e7-ba03-39085056ac2f Task timed out after 6.01 seconds

所以当我尝试初始化 SQS 客户端时，基本上会发生一些不好的事情，因为我看不到“完成”日志，导致 Lambda 超时。

我已经搜索了一些使用 java 的工作示例作为一个简单的出列的 lambda，但我找不到任何有值(value)的东西，只有没有 lambda 的 SQS SDK 示例。

我做错了什么吗？我可能需要在 Lambda 中使用另一个 SDK 吗？

Answer 1

这个问题的答案已经在问题的评论部分进行了讨论。但我想强调的是如果遇到这样的问题如何解决，这样这个问题就会得到答案，也可能对社区有所帮助。

当遇到 Lambda 未执行特定部分代码而终止的问题时，可能是由于以下原因造成的。

原因 1:Lambda 超时，甚至在完成处理之前。 Lambda 旨在成为可用于小型任务的无服务器架构。如果你想运行一个需要一直运行的进程，我推荐使用 EC2 实例。因此，每个 Lambda 函数都有一个超时来完成该过程。因此增加 Lambda 函数的超时时间可以解决这个问题。 (永远不要将超时设置为最多 5 分钟，因为意外的函数超时可能会让您付出很多代价)-这就是这个问题的答案。

原因 2:如果函数像在 NodeJS 中一样使用异步调用，您的 lambda 可以在您仍在执行异步调用时终止。因此，有一种机制，在所有异步调用都返回它们的值之前，lambda 不会终止。解决此问题的最佳方法是使用同步调用库而不是异步调用。

原因 3:代码中出现错误的最明显原因。这将终止 Lambda，您可以在其中看到错误并相应地修复它。

原因 4:这也可能是由于内存等资源分配不当造成的。如果您的函数需要一定的内存来执行，请通过预先估计在测试环境中运行该函数所需的正确值来预先分配它。