替换 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 信息 LambdaFunction:97 - 1480304495867
2016-11-28 03:41:41 信息 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 函数。