如何从 Java 代码调用 AWS lambda 函数/处理程序

Question

我是 AWS lambda 的新手我创建了一个带处理程序的 lambda 函数

example.Orders::orderHandler

这是自定义处理程序，现在我想从我的 Java 程序中调用它，我需要怎么做。

Answer 1

您在部署 Lambda 函数时定义处理程序。只有 AWS Lambda 服务需要知道您的自定义处理程序是什么。因此处理程序与调用该函数的 Java 代码无关。任何调用 Lambda 函数的东西只需要知道 Lambda 函数名称，而不是处理程序名称。

在 Java 中，您将通过记录在 here.

中的 AWSLambdaClient.invoke() 方法调用 Lambda 函数

Answer 2

这class中的2个方法应该能帮到你。一个用于是否需要传入有效负载，另一个用于有效负载为空。

但是，您需要记住一件事：函数名称可能与处理程序名称不同（这里的后者是example.Orders::orderHandler）。处理程序名称是 not 在调用其函数时使用。

所以，如果你有一个函数 函数名称 'myFunction' 在幕后调用你的 example.Orders::orderHandler handler，那么这就是您要传递给下面运行方法的内容。

import com.amazonaws.regions.Regions;
import com.amazonaws.services.lambda.AWSLambdaAsyncClient;
import com.amazonaws.services.lambda.model.InvokeRequest;
import com.amazonaws.services.lambda.model.InvokeResult;

class LambdaInvoker {

    public void runWithoutPayload(String region, String functionName) {
        runWithPayload(region, functionName, null);
    }

    public void runWithPayload(String region, String functionName, String payload) {
        AWSLambdaAsyncClient client = new AWSLambdaAsyncClient();
        client.withRegion(Regions.fromName(region));

        InvokeRequest request = new InvokeRequest();
        request.withFunctionName(functionName).withPayload(payload);
        InvokeResult invoke = client.invoke(request);
        System.out.println("Result invoking " + functionName + ": " + invoke);
    }
}

Answer 3

我按照以下代码打印了 Lambda 的响应

AWSLambdaAsyncClient lambdaClient = new AWSLambdaAsyncClient();
    lambdaClient.withRegion(Region.getRegion(Regions.US_WEST_2));
    InvokeRequest invokeRequest = new InvokeRequest();
    invokeRequest.setInvocationType("RequestResponse"); // ENUM RequestResponse or Event
    invokeRequest.withFunctionName("FUNCTION NAME").withPayload(payload);
    InvokeResult invoke = lambdaClient.invoke(invokeRequest);
    try {
        // PRINT THE RESPONSE
        String val = new String(invoke.getPayload().array(), "UTF-8");
        System.out.println("Response==> " + val);
    } catch (Exception e) {
        System.out.println("error");
    }

Answer 4

作为旁注，在 Eclipse 中创建 AWS Lambda Java 项目时，还必须添加

<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-java-sdk-lambda</artifactId>
    <version>1.11.411</version>
</dependency>

到 pom.xml 否则这些导入将失败：

import com.amazonaws.services.lambda.AWSLambdaAsyncClient;
import com.amazonaws.services.lambda.model.InvokeRequest;
import com.amazonaws.services.lambda.model.InvokeResult;

Answer 5

使用此最新代码同步调用 Lambda 函数：

    final String AWS_ACCESS_KEY_ID = "xx";
    final String AWS_SECRET_ACCESS_KEY = "xx";

    AWSCredentials credentials = new BasicAWSCredentials(AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY);

    // ARN
    String functionName = "XXXX";

    //This will convert object to JSON String
    String inputJSON = new Gson().toJson(userActivity);

    InvokeRequest lmbRequest = new InvokeRequest()
            .withFunctionName(functionName)
            .withPayload(inputJSON);

    lmbRequest.setInvocationType(InvocationType.RequestResponse);

    AWSLambda lambda = AWSLambdaClientBuilder.standard()
            .withRegion(Regions.US_EAST_1)
            .withCredentials(new AWSStaticCredentialsProvider(credentials)).build();

    InvokeResult lmbResult = lambda.invoke(lmbRequest);

    String resultJSON = new String(lmbResult.getPayload().array(), Charset.forName("UTF-8"));

    System.out.println(resultJSON);

使用这些依赖项来避免任何错误：

    <dependency>
        <groupId>org.codehaus.janino</groupId>
        <artifactId>janino</artifactId>
        <version>2.6.1</version>
    </dependency>

    //Required by BeanstalkDeploy.groovy at runtime
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.2</version>
        <scope>runtime</scope>
    </dependency>

    <dependency>
        <groupId>com.amazonaws</groupId>
        <artifactId>aws-java-sdk-lambda</artifactId>
        <version>1.11.207</version>
    </dependency>

如何从 Java 代码调用 AWS lambda 函数/处理程序

How to invoke the AWS lambda function / handler from Java code

java

aws-sdk

aws-lambda