java - Amazon SQS 调用 lambda 函数

Question

我正在尝试通过亚马逊 sqs 触发器触发功能。触发器工作正常，但是消息未传递到我的函数中。

这是我的 lambda 函数

import java.text.SimpleDateFormat;
import java.util.Calendar;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.LambdaLogger;
import com.amazonaws.services.lambda.runtime.RequestHandler;

public class x implements RequestHandler<RequestClass, ResponseClass> {
    private LambdaLogger logger;

    public void log(String message) {
        Calendar cal = Calendar.getInstance();
        SimpleDateFormat sdf = new SimpleDateFormat("MM-dd-yyyy HH:mm:ss");
        logger.log(sdf.format(cal.getTime()) + "  " + message+"\n");
    }

    public ResponseClass handleRequest(RequestClass request, Context context) {
        this.logger = context.getLogger();
        log("Request " + request);
        if (request == null || (request.getFilename() == null && request.getRecords() == null)) {
            log("No file was passed in");
            throw new RuntimeException("No file was passed in");
        }


        return new ResponseClass(null);
    }
}

请求类别为https://pastebin.com/Q1G6bnrA

当我看到日志时，记录总是为空。

Answer 1

您关注过Lambda的执行角色权限吗？

来自here :

执行角色权限

Lambda 需要以下权限来管理 Amazon SQS 队列中的消息。将它们添加到您的函数的执行角色中。

• sqs:接收消息
• sqs:删除消息
• sqs:获取队列属性