我很难使用基于Java的Lambda函数设置来接收来自SNS的消息.我的功能如下所示:
package com.mycompany;
import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.LambdaLogger;
import com.amazonaws.services.lambda.runtime.events.SNSEvent;
public class LambdaHandler {
public void Handler(SNSEvent event, Context context) {
//Process the event
}
}
Run Code Online (Sandbox Code Playgroud)
它编译得很好,我没有任何问题上传jar文件到Lambda(通过Web控制台).
但是,当我使用表示SNSEvent模型的JSON发布它(通过SNS到订阅的Lambda函数)时,Lambda函数抛出以下异常:
在类com.mycompany.LambdaHandler上加载方法处理程序时出错:class java.lang.NoClassDefFoundError java.lang.NoClassDefFoundError:com/amazonaws/services/lambda/runtime/events/SNSEvent at
爪哇java.lang.Class.Class.AvlaredMethods(Class.java:2701)的java.lang.Class.getDeclaredMethods0(本地方法)java.lang.Class.TM中的java.lang.Class.privateGetPublicMethods(Class.java:2902) Class.java:1615)引起:java.lang.ClassNotFoundException:com.amazonaws.services.lambda.runtime.events.SNSEvent at java.net.URLClassLoader.findClass(URLClassLoader.java:381)at java.lang.ClassLoader. java.lang.ClassLoader.loadClass(ClassLoader.java:357)中的loadClass(ClassLoader.java:424)
我使用Maven + Netbeans,它是一个Maven Java Application项目.我从Lambda控制台下载了该函数并确认,该jar有一个lib /目录,其中包含所有用于导入的jar,包括aws-lambda-java-events-1.1.0.jar,它本身包含/ com/amazonaws /services/lambda/runtime/events/SNSEvent.class文件.
为什么运行时无法在jar文件中找到类?还有什么我需要做的,设置任何环境变量等吗?
任何帮助,将不胜感激!
编辑1 我尝试降级到aws-lambda-java-events 1.0.0并且它仍然报告相同的异常.根据要求,下面是我的POM文件(只更改了项目名称).我不知道如何告诉Maven将库放在树形结构中.
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.app</groupId>
<artifactId>Handler</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<dependencies>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-lambda</artifactId>
<version>1.10.6</version>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-lambda-java-core</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-lambda-java-events</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies> …Run Code Online (Sandbox Code Playgroud) 我有几个lambda通过SNS一起工作.一个lambda接收请求并将数据发送到SNS.另一个lambda订阅了SNS.在JavaScript中很容易做,因为传入的消息只是一个JS对象.现在我将lambda重写为Java.我正在寻找在处理程序中使用的类型.
这就是lambda的样子.SNSMessage是该类型的占位符.
public class ArchiveRequestHandler implements RequestHandler<SNSMessage?, Void> {
@Override public Void handleRequest(SNSMessage? input, Context context) {
// do something with the message
return null;
}
}
Run Code Online (Sandbox Code Playgroud)
这是示例消息的样子:
{
"Records": [
{
"EventVersion": "1.0",
"EventSubscriptionArn": "arn:aws:sns:EXAMPLE",
"EventSource": "aws:sns",
"Sns": {
"SignatureVersion": "1",
"Timestamp": "1970-01-01T00:00:00.000Z",
"Signature": "EXAMPLE",
"SigningCertUrl": "EXAMPLE",
"MessageId": "1234567-ee98-5cb9-9903-4c221d41eb5e",
"Message": "Hello from SNS!",
"MessageAttributes": {
"Test": {
"Type": "String",
"Value": "TestString"
},
"TestBinary": {
"Type": "Binary",
"Value": "TestBinary"
}
},
"Type": "Notification",
"UnsubscribeUrl": "EXAMPLE",
"TopicArn": "arn:aws:sns:EXAMPLE",
"Subject": "TestInvoke"
} …Run Code Online (Sandbox Code Playgroud)