AWS Lambda invokeAsync（已弃用）的替代方案

Question

我正在尝试在一个Java Lambda函数内异步调用另一个Java Lambda函数。 我只想发出请求而不等待结果，但是使用.invokeAsync(InvokeRequest)，我必须在Future上调用.get()，这会阻塞并破坏"发出请求而不等待结果"的用例。

这是我正在尝试使用的代码:

private void sendToDownloader(String payload) throws InterruptedException, ExecutionException {
    log.info(payload);
    InvokeRequest invoke = new InvokeRequest();
    invoke.withFunctionName("LambdaTwo")
            .withPayload(payload)
            .withInvocationType(InvocationType.Event);

    lambdaClient.invokeAsync(invoke).get();
}

如果我去掉 .get() 方法的调用，LambdaTwo 实际上并不会被调用。

值得注意的是，这个 lambda 函数在调用 LambdaTwo 后立即结束。

同时，我尝试使用以下代码:

private void sendToDownloader(String payload) throws InterruptedException, ExecutionException {
    log.info(payload);
    InvokeAsyncRequest invoke = new InvokeAsyncRequest();
    invoke.withFunctionName("LambdaTwo")
            .withInvokeArgs(payload);

    lambdaClient.invokeAsync(invoke);
}

这段代码可以工作，但是 .invokeAsync 方法已经被弃用了，而且建议查看“Invoke API”，但我找不到任何相关文档。

有人能指导我以一种纯“发送并忘记”的方式调用 Lambda 函数的正确方法吗？

编辑 1 根据 Mark 的建议，我已经重新编写了下面的代码，但它似乎在 LambdaTwo 函数执行时会阻塞。

public void routeEvent(String lambdaName, String cacheName) throws InterruptedException, ExecutionException, JsonProcessingException {
    ObjectNode obj = new ObjectNode(JsonNodeFactory.instance);
    obj.put("nodeName", cacheName);
    InvokeRequest invoke = new InvokeRequest();
    invoke.withFunctionName(lambdaName)
            .withInvocationType(InvocationType.Event)
            .withPayload(OBJECT_MAPPER.writeValueAsString(obj));

    log.info(System.currentTimeMillis());
    lambdaClient.invoke(invoke);
    log.info(System.currentTimeMillis());
}

它打印出以下毫秒数。

2016-11-28 03:41:35 INFO LambdaFunction:97 - 1480304495867
2016-11-28 03:41:41 INFO LambdaFunction:99 - 1480304501432

两者之间相差约5.5秒，并且Lambda持续时间也证实了这一点。

编辑2 为了澄清一下，我正在尝试使用AWSLambdaAsyncClient调用.invokeAsync(InvokeRequest)和.invoke(InvokeRequest)，但都无法正常工作。当调用invokeAsync时，它实际上不会调用Lambda函数，除非我在其上调用.get()，而后者将在第二个Lambda函数执行时阻塞。

最终成功的方法是调用.invokeAsync(InvokeRequest)，然而不要在InvokeRequest对象上调用.withInvocationType(InvocationType.Event)。并不清楚为什么这会导致异步行为，但这就是有效的方法，而且不使用已弃用的方法。

public void routeEventAsync2(String lambdaName, String cacheName) throws InterruptedException, ExecutionException, JsonProcessingException {
    ObjectNode obj = new ObjectNode(JsonNodeFactory.instance);
    obj.put("nodeName", cacheName);
    InvokeRequest invoke = new InvokeRequest();
    invoke.withFunctionName(lambdaName)
            .withPayload(OBJECT_MAPPER.writeValueAsString(obj));

    lambdaAsyncClient.invokeAsync(invoke);
}

- Brooks

Answer 1

关于此方法弃用的文档很混乱，他们想表达的是使用 AWSLambdaClient.invoke(request) 方法。您需要在请求对象上设置 InvocationType 为 Event，以便调用 Lambda 函数而不等待响应。

- Mark B

---

那么，整个AWSLambdaAsyncClient都已经过时了吗？AWSLambdaClient的Javadoc说所有服务调用都会阻塞... - Brooks

你在问题中没有提到你使用了 AWSLambdaAsyncClient。查看该类的 Java 文档，它只声明了 invokeAsyncAsync() 方法已弃用。你正在使用的 invokeAsync() 方法应该是可行的。http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/lambda/AWSLambdaAsyncClient.html - Mark B

抱歉，我应该提到这一点。我通过您的答案得出了正确的答案，但由于某种原因将InvocationType设置为Event导致同步行为。 - Brooks

那么，为了实现异步行为，InvocationType 应该设置为什么？DryRun / Event / RequestResponse - Baked Inhalf