AWS Lambda invokeAsync的替换(不建议使用)

Question

我试图从另一个Java Lambda函数异步调用Java Lambda函数.我只是想解雇并忘记,但是使用.invokeAsync(InvokeRequest),我必须在Future上调用.get(),然后阻止并打破'fire and forget'用例.

这是我尝试使用的代码:

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). 您需要在请求对象上设置InvocationTypeto Event，以便在不等待响应的情况下调用 Lambda 函数。