如何从 aws lambda 在 ec2 上调用 grpc 服务 运行
How to call a grpc service running on ec2 from aws lambda
我有一个 grpc 服务,用 python 编写,部署在一个 EC2 实例上。我已经编写了一个 nodejs 应用程序并使用该应用程序,我能够从我的本地计算机以及另一个 EC2 实例调用 grpc 服务。但是,当我将相同的应用程序部署到 Lambda(使用无服务器部署)时,它无法调用相同的 grpc 服务。
我在 package.json 的脚本部分添加了以下行,以便代码能够正确部署到 lambda。
"postinstall": "npm rebuild grpc --target=12.x --target_arch=x64 --target_platform=linux --target_libc=glibc"
最初 lambda 执行时没有任何错误,只是它没有调用 grpc 服务。
之后,我在 serverless.yml 文件中添加了 VPC 端点配置,它在 cloudwatch 中返回内部服务器错误和日志记录错误 "EACCES: permission denied, open '/var/task/handler.js'"。
更新: 我更新了 IAM 角色,现在没有错误记录,但 lambda 始终响应 "Go Serverless v1.0! Your function executed successfully!"。
None 我尝试在 utterQuery 方法的回调中记录的消息已记录在 cloudwatch 日志中。
这里可能有什么问题。
这是 serverless.yml 文件:
service: myservice
provider:
name: aws
runtime: nodejs12.x
vpc:
securityGroupIds:
- securityGroupid1
subnetIds:
- subnetId1
stage: dev
region: us-east-1
stackTags:
owner: me
functions:
sendMessage:
handler: handler.sendMessage
events:
- http:
path: sendMessage
method: post
这是 lambda 函数代码:
'use strict';
const AWS = require('aws-sdk');
const grpcClient = require('./grpcClient');
module.exports.sendMessage = async (event, context) => {
const timestamp = new Date().getTime();
console.log(event, timestamp);
console.log(event.body);
const message = event.body;
let reply = 'Go Serverless v1.0! Your function executed successfully!';
grpcClient.utterQuery({
query: message,
user_id: 10101,
session_id: 321
}, (error, riaReply) => {
if (error) {
console.error(error)
} else {
console.log('successfully queried grpc service.')
console.log(riaReply.response)
}
});
return {
statusCode: 200,
body: reply
};
};
由于您在处理程序末尾调用 return
,lambda 调用在 utterQuery()
调用有机会完成之前结束,调用是回调。
https://docs.aws.amazon.com/lambda/latest/dg/nodejs-prog-model-handler.html 建议您 return 一个承诺,并且 node.js lambda 运行时将知道在结束 lambda 之前等待该承诺实现。
我有一个 grpc 服务,用 python 编写,部署在一个 EC2 实例上。我已经编写了一个 nodejs 应用程序并使用该应用程序,我能够从我的本地计算机以及另一个 EC2 实例调用 grpc 服务。但是,当我将相同的应用程序部署到 Lambda(使用无服务器部署)时,它无法调用相同的 grpc 服务。 我在 package.json 的脚本部分添加了以下行,以便代码能够正确部署到 lambda。
"postinstall": "npm rebuild grpc --target=12.x --target_arch=x64 --target_platform=linux --target_libc=glibc"
最初 lambda 执行时没有任何错误,只是它没有调用 grpc 服务。 之后,我在 serverless.yml 文件中添加了 VPC 端点配置,它在 cloudwatch 中返回内部服务器错误和日志记录错误 "EACCES: permission denied, open '/var/task/handler.js'"。
更新: 我更新了 IAM 角色,现在没有错误记录,但 lambda 始终响应 "Go Serverless v1.0! Your function executed successfully!"。 None 我尝试在 utterQuery 方法的回调中记录的消息已记录在 cloudwatch 日志中。
这里可能有什么问题。
这是 serverless.yml 文件:
service: myservice
provider:
name: aws
runtime: nodejs12.x
vpc:
securityGroupIds:
- securityGroupid1
subnetIds:
- subnetId1
stage: dev
region: us-east-1
stackTags:
owner: me
functions:
sendMessage:
handler: handler.sendMessage
events:
- http:
path: sendMessage
method: post
这是 lambda 函数代码:
'use strict';
const AWS = require('aws-sdk');
const grpcClient = require('./grpcClient');
module.exports.sendMessage = async (event, context) => {
const timestamp = new Date().getTime();
console.log(event, timestamp);
console.log(event.body);
const message = event.body;
let reply = 'Go Serverless v1.0! Your function executed successfully!';
grpcClient.utterQuery({
query: message,
user_id: 10101,
session_id: 321
}, (error, riaReply) => {
if (error) {
console.error(error)
} else {
console.log('successfully queried grpc service.')
console.log(riaReply.response)
}
});
return {
statusCode: 200,
body: reply
};
};
由于您在处理程序末尾调用 return
,lambda 调用在 utterQuery()
调用有机会完成之前结束,调用是回调。
https://docs.aws.amazon.com/lambda/latest/dg/nodejs-prog-model-handler.html 建议您 return 一个承诺,并且 node.js lambda 运行时将知道在结束 lambda 之前等待该承诺实现。