如何在另一个AWS Java Lambda函数中调用aws java lambda函数,当它们位于同一帐户,同一区域时

Question

我有一个java aws lambda函数或处理程序作为AHandler来做一些事情,例如它已经订阅了SNS事件,它解析了SNS事件并将相关数据记录到数据库中.

我有另一个java aws lambda BHandler,这个BHandler的目标是从AHandler接收请求并向AHandler提供响应.因为BHandler的目标是提供一些json数据的响应.这将由AHandler使用.

我是否可以看到任何明确的例子,告诉我们如何做这些事情？

我看到这个例子调用lambda函数从Java类以及从Java调用lambda函数

我的问题讨论了这种情况,当一个aws java lambda函数(或处理程序)调用另一个aws java lambda函数时,两者都在同一个区域,相同的帐户,相同的vpc执行的东西,相同的权限.在那种情况下,aws java lambda函数可以直接调用(或调用)到另一个或仍然必须提供aws键,区域等东西(如上面的链接)？一个明确的例子/解释将非常有帮助.

编辑

正在调用另一个Lambda函数(BHandler)的AHandler,存在于同一个帐户上已经给出了完整的AWSLambdaFullAccess所有内容,例如

"iam:PassRole","lambda:*",

这是要调用的代码:

注意:当我使用普通java main函数调用相同的函数时,下面的代码可以工作.但它不像在lambda函数上调用(就像ALambdaHandler调用BLambdaHandler作为函数调用).即使它没有返回任何例外.它只是显示超时,它被困在:lambdaClient.invoke的代码

String awsAccessKeyId = PropertyManager.getSetting("awsAccessKeyId");
        String awsSecretAccessKey = PropertyManager.getSetting("awsSecretAccessKey");
        String regionName = PropertyManager.getSetting("regionName");
        String geoIPFunctionName = PropertyManager.getSetting("FunctionName");

        Region region;
        AWSCredentials credentials;
        AWSLambdaClient lambdaClient;

        credentials = new BasicAWSCredentials(awsAccessKeyId,
                awsSecretAccessKey);

        lambdaClient = (credentials == null) ? new AWSLambdaClient()
                : new AWSLambdaClient(credentials);
        region = Region.getRegion(Regions.fromName(regionName));
        lambdaClient.setRegion(region);


        String returnGeoIPDetails = null;

        try {


            InvokeRequest invokeRequest = new InvokeRequest();
            invokeRequest.setFunctionName(FunctionName);
            invokeRequest.setPayload(ipInput);


            returnDetails = byteBufferToString(
                    lambdaClient.invoke(invokeRequest).getPayload(),
                    Charset.forName("UTF-8"),logger);
        } catch (Exception e) {

            logger.log(e.getMessage());
        }

编辑 我按照其他人的建议做了一切,并遵循了一切.最后我达到了AWS支持,问题与一些VPC配置相关,并且已经解决了.如果你遇到类似的东西,那么可能会检查安全配置,VPC的东西.

Answer 1

我们通过使用com.amazonaws.services.lambda.model.InvokeRequest实现了这一点.这是代码示例.

public class LambdaInvokerFromCode {
     public void runWithoutPayload(String functionName) {
            runWithPayload(functionName, null);
        }

        public void runWithPayload(String functionName, String payload) {
            AWSLambdaAsyncClient client = new AWSLambdaAsyncClient();
            client.withRegion(Regions.US_EAST_1);

            InvokeRequest request = new InvokeRequest();
            request.withFunctionName(functionName).withPayload(payload);
            InvokeResult invoke = client.invoke(request);
            System.out.println("Result invoking " + functionName + ": " + invoke);
    }



    public static void main(String[] args) {
            String KeyName ="41159569322017486.json";
            String status = "success";
            String body = "{\"bucketName\":\""+DBUtils.S3BUCKET_BULKORDER+"\",\"keyName\":\""+KeyName+"\", \"status\":\""+status+"\"}";
            System.out.println(body);

            JSONObject inputjson = new JSONObject(body); 
            String bucketName = inputjson.getString("bucketName");
            String keyName = inputjson.getString("keyName");
            String Status = inputjson.getString("status");
            String destinationKeyName = keyName+"_"+status;
            LambdaInvokerFromCode obj = new LambdaInvokerFromCode();
            obj.runWithPayload(DBUtils.FILE_RENAME_HANDLER_NAME,body);
        }
}

Answer 2

• 确保执行 Lambda 函数的角色具有lambda:InvokeFunction权限。
• 然后使用AWS SDK调用第二个函数。（文档：http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/lambda/AWSLambdaClient.html#invoke(com.amazonaws.services.lambda.model.InvokeRequest)）

编辑：对于这种情况，请考虑使用Step Functions。