AWS - Lambda 无法通过 Python SDK 调用另一个 lambda

Question

我正在尝试使用 python SDK 从另一个 lambda 调用 lambda 函数。这两个 lambda 函数属于同一个 VPC。触发器 lambda 仅包含调用第二个 lambda (loader_development) 的 python 脚本。 loader_development lambda 的 APIGateway 是私有的，它配置了一个资源策略，拒绝访问不属于该特定 VPC 的所有 IP 地址。

我在触发器 lambda 中的 Python 脚本是：

from __future__ import print_function

import json
import logging
import os
from urllib2 import urlopen,Request,HTTPError
import boto3

logger = logging.getLogger()
logger.setLevel(logging.INFO)
region = os.environ['AWS_REGION']

def lambda_handler(event, context):
    invokeLambda = boto3.client('lambda', region_name = 'us-east-1')  
    request = {'resource':'/bucketstatus/latest','path':'/bucketstatus/latest','httpMethod':'GET'}
    invoke_response = invokeLambda.invoke(FunctionName='loader_development',
                                           InvocationType='RequestResponse',
                                           Payload=json.dumps(request))
    print(invoke_response['Payload'].read())

logger.info('Process Complete')

所以 /bucketstatus/latest 是一个 GET 请求，这个端点位于 loader_development lambda 的 APIGateway（私有）中。 loader_development lambda 是一个 spring 启动应用程序，而触发器 lambda 是一个独立的 lambda，它只有一个 python 脚本来调用 loader_development lambda 的端点以获取响应.

测试此脚本时，它给出了 500 状态和内部服务器错误。错误：

2019-10-09 10:09:09.279 ERROR 1 --- [ main] c.a.s.proxy.AwsProxyExceptionHandler : Called exception handler for:
com.amazonaws.serverless.exceptions.InvalidRequestEventException: The incoming event is not a valid request from Amazon API Gateway or an Application Load Balancer
10:09:09 at com.amazonaws.serverless.proxy.internal.servlet.AwsProxyHttpServletRequestReader.readRequest(AwsProxyHttpServletRequestReader.java:41)
10:09:09 at com.amazonaws.serverless.proxy.internal.servlet.AwsProxyHttpServletRequestReader.readRequest(AwsProxyHttpServletRequestReader.java:28)
10:09:09 at com.amazonaws.serverless.proxy.internal.LambdaContainerHandler.proxy(LambdaContainerHandler.java:174)
10:09:09 at com.amazonaws.serverless.proxy.internal.LambdaContainerHandler.proxyStream(LambdaContainerHandler.java:209)
10:09:09 at com.trimble.roadrunner.StreamLambdaHandler.handleRequest(StreamLambdaHandler.java:49)
10:09:09 at lambdainternal.EventHandlerLoader.call(EventHandlerLoader.java:888)
10:09:09 at lambdainternal.AWSLambda.startRuntime(AWSLambda.java:293)
10:09:09 at lambdainternal.AWSLambda.<clinit>(AWSLambda.java:64)
10:09:09 at java.lang.Class.forName0(Native Method)
10:09:09 at java.lang.Class.forName(Class.java:348)
10:09:09 at lambdainternal.LambdaRTEntry.main(LambdaRTEntry.java:114)

奇怪的是，当我尝试调用其他一些 lambda（微服务）时，请求得到处理并且状态为 200。示例 lambda 也在 VPC 中并且具有私有 APIGateway。

我真的不确定我错过了什么。任何帮助将不胜感激！

Answer 1

W.R.T。 GitHub 解决方案，我收到此异常是因为我没有在请求对象中包含 requestContext 属性。所以我将我的请求对象修改为：

request = {'resource': '/bucketstatus/latest', 'path': '/bucketstatus/latest', 'httpMethod': 'GET',
               'requestContext':{'accountId':'821665253511',
                                 'resourceId': '',
                                  'stage': 'development',
                                  'requestId': context.aws_request_id,
                                  'identity': {
                                     'cognitoIdentityPoolId': None,
                                     'accountId': None,
                                     'cognitoIdentityId': None,
                                     'caller': None,
                                     'apiKey': None,
                                     'sourceIp': '',
                                     'cognitoAuthenticationType': None,
                                     'cognitoAuthenticationProvider': None,
                                     "userArn":context.invoked_function_arn
                                  }
                                },
                "apiId": "No need"
               }

此更改后，我能够获得状态代码为 200 的正确响应。

AWS - Lambda 无法通过 Python SDK 调用另一个 lambda

AWS - Lambda unable to invoke another lambda through Python SDK

python

amazon-web-services

aws-sdk

aws-lambda

aws-api-gateway