node.js - AWS Lambda 函数可以调用另一个函数吗

Question

我有 2 个 Lambda 函数 - 一个产生报价，另一个将报价转化为订单。我希望 Order lambda 函数调用 Quote 函数来重新生成报价，而不是仅仅从不受信任的客户端接收它。

我已经看过我能想到的所有地方 - 但看不到我将如何链接或调用函数......当然这存在！

score 443 · Accepted Answer

我找到了一种使用aws-sdk.

var aws = require('aws-sdk');
var lambda = new aws.Lambda({
  region: 'us-west-2' //change to your region
});

lambda.invoke({
  FunctionName: 'name_of_your_lambda_function',
  Payload: JSON.stringify(event, null, 2) // pass params
}, function(error, data) {
  if (error) {
    context.done('error', error);
  }
  if(data.Payload){
   context.succeed(data.Payload)
  }
});

您可以在此处找到文档：http: //docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Lambda.html

score 138 · Accepted Answer

你应该链接你的Lambda functionsvia SNS。这种方法以最小的努力提供了良好的性能、延迟和可扩展性。

您的第一个Lambda向您发布消息，SNS Topic第二个Lambda订阅此主题。消息到达主题后，第二个Lambda消息将作为输入参数执行。

请参阅使用 Amazon SNS 通知调用 Lambda 函数。

您还可以使用此方法通过 SNS 调用跨账户 Lambda 函数。

score 96 · Accepted Answer

这是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": "*"
    }

score 43 · Accepted Answer

自从提出这个问题后，亚马逊发布了 Step Functions ( https://aws.amazon.com/step-functions/ )。

AWS Lambda 背后的核心原则之一是，您可以更多地关注业务逻辑，而更少关注将它们联系在一起的应用程序逻辑。Step Functions 允许您编排函数之间的复杂交互，而无需编写代码来执行此操作。

score 16 · Accepted Answer

此解决方案是使用 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

score 12 · Accepted Answer

在Lambda 客户端文档（Java 版本）中看到这一点之前，我一直在考虑删除 SNS ：

用于访问 AWS Lambda 的客户端。使用此客户端进行的所有服务调用都是阻塞的，并且在服务调用完成之前不会返回。

所以 SNS 有一个明显的优势：它是异步的。您的 lambda 不会等待后续 lambda 完成。

score 10 · Accepted Answer

亚马逊于 2016 年在 AWS lambda 中引入了 steps 函数。我认为，现在使用 steps 函数更方便，因为它真的很容易使用。您可以构建具有两个 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 Functions

score 6 · Accepted Answer

在java中，我们可以这样做：

AWSLambdaAsync awsLambdaAsync = AWSLambdaAsyncClientBuilder.standard().withRegion("us-east-1").build();

InvokeRequest invokeRequest = new InvokeRequest();
invokeRequest.withFunctionName("youLambdaFunctionNameToCall").withPayload(payload);

InvokeResult invokeResult = awsLambdaAsync.invoke(invokeRequest);

在这里，有效负载是您的字符串化java 对象，需要将其作为 Json 对象传递给另一个 lambda，以防您需要将一些信息从调用 lambda 传递给被调用 lambda。

score 5 · Accepted Answer

我正在使用blueskin提供的答案，但我无法读取 Payload 响应，因为InvocationType='Event'是async，所以我更改为 InvocationType='RequestResponse' 现在一切正常。

score 5 · Accepted Answer

有很多答案，但没有人强调调用另一个 lambda 函数不是同步调用的推荐解决方案，而您应该使用的实际上是Step Functions

不推荐解决方案的原因：

当它们相互等待时，您为这两个功能付费
您的代码负责重试

您还可以将它用于相当复杂的逻辑，例如并行步骤和捕获故障。每次执行也会被注销，这使得调试更加简单。

score 3 · Accepted Answer

您也许可以使用 Async.js 瀑布功能 - 请参阅本文档第 3 步中大代码块的底部以获取示例：

https://aws.amazon.com/blogs/compute/better-together-amazon-ecs-and-aws-lambda/

score 3 · Accepted Answer

其他人指出使用 SQS 和 Step Functions。但是这两种解决方案都会增加额外的成本。Step Function 状态转换据说非常昂贵。

AWS lambda 提供了一些重试逻辑。它尝试了 3 次。我不确定当您使用 API 触发它时这是否仍然有效。

score 3 · Accepted Answer

这是调用另一个 lambda 函数并获取其响应的 python 示例。有两种调用类型'RequestResponse'和'Event'。如果要获取 lambda 函数的响应，请使用“RequestResponse”，并使用“Event”异步调用 lambda 函数。所以异步和同步两种方式都可用。

    lambda_response = lambda_client.invoke(
                FunctionName = lambda_name,
                InvocationType = 'RequestResponse',
                Payload = json.dumps(input)
                )
    resp_str = lambda_response['Payload'].read()
    response = json.loads(resp_str)

score 2 · Accepted Answer

您可以按照 AWS 的博客文章AWSLambdaClient中的描述直接调用 lambda 函数（至少通过 Java）。

score 2 · Accepted Answer

我遇到了同样的问题，但我实现的 Lambda 函数将在 DynamoDB 中插入一个条目，因此我的解决方案使用 DynamoDB 触发器。

我让数据库为表中的每个插入/更新调用一个 Lambda 函数，因此这将两个 Lambda 函数的实现分开。

文档在这里： http ://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

这是一个指导演练： https ://aws.amazon.com/blogs/aws/dynamodb-update-triggers-streams-lambda-cross-region-replication-app/

score 1 · Accepted Answer

一种迂回的解决方案，但是当我需要链接它们时，我只是为我的 lambda 函数调用API 端点。这使您可以在编码时决定是否希望它们是异步的。

如果您不想设置 POST 请求，您可以设置一个简单的 GET 请求，其中有几个或根本没有，查询字符串参数以便于事件传递。

- 编辑 -

请参阅：https ://docs.aws.amazon.com/apigateway/api-reference/making-http-requests/

和：http ://docs.aws.amazon.com/lambda/latest/dg/with-on-demand-https-example.html

score 0 · Accepted Answer

您可以直接从其他 Lambda 函数以异步方式直接触发 Lambda 函数。

https://docs.aws.amazon.com/lambda/latest/dg/invocation-async.html#invocation-async-destinations

score -3 · Accepted Answer

您可以设置 AWS_REGION 环境。

assert(process.env.AWS_REGION, 'Missing AWS_REGION env (eg. ap-northeast-1)');
const aws = require('aws-sdk');
const lambda = new aws.Lambda();

node.js - AWS Lambda 函数可以调用另一个函数吗

18 回答 18

Related

Reference