我试图从另一个
Java Lambda函数异步调用Java Lambda函数.我只是想解雇并忘记,但是使用.invokeAsync(InvokeRequest),我必须在Future上调用.get(),然后阻止并打破’fire and forget’用例.
@H_502_40@解决方法
这是我尝试使用的代码：
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);
}
