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"，我找不到任何文档。

任何人都可以引导我找到以纯粹 'fire and forget' 方式调用 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 函数。

AWS Lambda invokeAsync 的替代品（已弃用）

Replacement for AWS Lambda invokeAsync (deprecated)

java

amazon-web-services

aws-sdk

aws-lambda