java - 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澄清一下，我正在尝试调用 .invokeAsync(InvokeRequest) 和 .invoke(InvokeRequest) 的 AWSLambdaAsyncClient，但均无效。调用 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);
}

Answer 1

有关弃用此方法的文档令人困惑。他们想说的是使用 AWSLambdaClient.invoke(request)。您需要将请求对象的 InvocationType 设置为 Event，以便在不等待响应的情况下调用 Lambda 函数。