我有2个Lambda函数——一个生成报价,一个将报价转换为订单。 我希望Order lambda函数调用Quote函数来重新生成报价,而不是仅仅从不受信任的客户端接收报价。
我已经看遍了我能想到的所有地方——但不知道我该如何链接或调用函数……这当然存在!
我有2个Lambda函数——一个生成报价,一个将报价转换为订单。 我希望Order lambda函数调用Quote函数来重新生成报价,而不是仅仅从不受信任的客户端接收报价。
我已经看遍了我能想到的所有地方——但不知道我该如何链接或调用函数……这当然存在!
当前回答
亚马逊于2016年在AWS lambda中引入了步骤函数。我认为,现在使用步骤函数更方便,因为它真的很容易使用。你可以用两个lambda函数构建一个状态机:
产生一个报价 将报价转化为订单
你可以很容易地做到如下:
在这里,您可以使用第一个状态生成报价,另一个状态转换为订单
{
Comment: "Produce a quote and turns into an order",
StartAt: "ProduceQuote",
States: {
ProduceQuote: {
"Type": Task,
"Resource": "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
"next": TurnsToOrder
}
TurnsToOrder: {
Type: Task,
Resource: "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
end: true
}
}
}
Steps函数使得编写多个lambda函数并按顺序或并行运行变得非常容易。 你可以在这里获得更多关于lambda steps函数的信息: 步骤的功能
其他回答
这个解决方案是使用boto3和Python完成的:
import boto3
import json
lambda_client = boto3.client('lambda', region_name='eu-west-1')
def lambda_handler(event, context):
lambda_client.invoke(FunctionName = 'function_name', InvocationType = 'RequestResponse', Payload = json.dumps(event))
return True
亚马逊于2016年在AWS lambda中引入了步骤函数。我认为,现在使用步骤函数更方便,因为它真的很容易使用。你可以用两个lambda函数构建一个状态机:
产生一个报价 将报价转化为订单
你可以很容易地做到如下:
在这里,您可以使用第一个状态生成报价,另一个状态转换为订单
{
Comment: "Produce a quote and turns into an order",
StartAt: "ProduceQuote",
States: {
ProduceQuote: {
"Type": Task,
"Resource": "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
"next": TurnsToOrder
}
TurnsToOrder: {
Type: Task,
Resource: "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
end: true
}
}
}
Steps函数使得编写多个lambda函数并按顺序或并行运行变得非常容易。 你可以在这里获得更多关于lambda steps函数的信息: 步骤的功能
下面是python的示例代码,
from boto3 import client as boto3_client
from datetime import datetime
import json
lambda_client = boto3_client('lambda')
def lambda_handler(event, context):
msg = {"key":"new_invocation", "at": datetime.now()}
invoke_response = lambda_client.invoke(FunctionName="another_lambda_",
InvocationType='Event',
Payload=json.dumps(msg))
print(invoke_response)
顺便说一句,您还需要向您的lambda角色添加这样的策略
{
"Sid": "Stmt1234567890",
"Effect": "Allow",
"Action": [
"lambda:InvokeFunction"
],
"Resource": "*"
}
以下是如何在javascript/typescript中做到这一点,而无需安装完整的aws-sdk包。
import { InvokeCommand, LambdaClient, LogType } from "@aws-sdk/client-lambda";
const client = new LambdaClient({
region: "US-EAST-1"
});
const payload = JSON.stringify({
data: "your input"
})
const command = new InvokeCommand({
FunctionName: "your function name",
Payload: payload,
LogType: LogType.Tail,
});
const { Payload } = await client.send(command);
const response: any = Payload;
const result = Buffer.from(response).toString();
return result;
我一直在考虑删除SNS,直到我在Lambda客户端文档(Java版本)中看到了这个:
访问AWS Lambda的客户端。使用此客户端进行的所有服务调用都是阻塞的,直到服务调用完成才返回。
所以SNS有一个明显的优势:它是异步的。你的lambda不会等待后续的lambda完成。