python - AWS - Lambda 无法通过 Python SDK 调用另一个 lambda
问题描述
我正在尝试使用 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 boot 应用程序,而 trigger 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$2.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。
我真的不确定我错过了什么。任何帮助将不胜感激!
解决方案
WRT 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 的正确响应。
推荐阅读
- javascript - 一个标记与两端定义的折线之间的最近距离
- java - toInstant() java 返回错误值
- react-hooks - 从 api 异步方式获取数据时,反应功能组件被调用 3 次
- amazon-web-services - 使用 Codebuild 时的 S3 策略
- github - circle ci 工作流程何时运行?
- python - 如何使用 Beautiful soup python 将 Div 中的所有详细信息导出到 excel/csv?
- python - scrapy.http.request 不执行来自 Scrapy 的回调
- javascript - 反应多个 onChange 事件...一个用于验证一个用于格式化输入
- arrays - printf struct 像一个数组 C
- python - PYTHON:处理 KeyError