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

我试图从另一个 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,cacheName);
    InvokeRequest invoke = new InvokeRequest();
    invoke.withFunctionName(lambdaName)
            .withPayload(OBJECT_MAPPER.writeValueAsString(obj));

    lambdaAsyncClient.invokeAsync(invoke);
}