如何在Lambda函数中调用另一个Lambda并实现顺序执行、传参与获响应？

我来给你分享几个AWS生态里常用的实现方式，你可以根据自己的业务复杂度来选：

方案一：直接通过AWS SDK同步调用（最直接，适合简单场景） #

这是最直观的方式，第一个Lambda直接调用第二个Lambda的API，同步等待执行结果，完全符合你“先执行第一个，再执行第二个”的需求。

1. 配置IAM权限 #

首先得给第一个Lambda的执行角色加上调用第二个Lambda的权限，否则会报权限错误。示例IAM策略如下：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "lambda:InvokeFunction",
            "Resource": "arn:aws:lambda:你的区域:你的账号ID:function:第二个Lambda的函数名"
        }
    ]
}

2. 在第一个Lambda里编写调用代码（以Python为例） #

用boto3 SDK直接调用，同时传递数据、获取响应：

import boto3
import json

lambda_client = boto3.client('lambda')

def lambda_handler(event, context):
    # 第一步：你的业务逻辑——从数据库取数据写入DynamoDB
    # ... 这里写你的原有代码 ...
    
    # 准备要传给第二个Lambda的数据
    payload_data = {
        "key1": "value1",
        "dynamodb_table": "你的表名",
        "some_data": "从数据库拿到的内容"
    }
    
    # 调用第二个Lambda，同步等待响应
    response = lambda_client.invoke(
        FunctionName='第二个Lambda的函数名',
        InvocationType='RequestResponse',  # 同步调用必须用这个值
        Payload=json.dumps(payload_data)
    )
    
    # 解析第二个Lambda的响应
    second_lambda_response = json.loads(response['Payload'].read())
    print("第二个Lambda的返回结果：", second_lambda_response)
    
    # 后续处理逻辑
    return {
        'statusCode': 200,
        'body': json.dumps({'first_lambda_result': '完成写入', 'second_lambda_result': second_lambda_response})
    }

3. 第二个Lambda接收数据的示例 #

第二个Lambda可以直接从event参数里拿到传递的数据：

import json

def lambda_handler(event, context):
    # 接收第一个Lambda传来的数据
    received_data = event
    print("收到的数据：", received_data)
    
    # 第二步：你的业务逻辑——从DynamoDB读取数据
    # ... 这里写你的原有代码 ...
    
    # 返回响应给第一个Lambda
    return {
        'statusCode': 200,
        'body': json.dumps({'read_result': '从DynamoDB拿到的内容'})
    }

方案二：用Step Functions编排（推荐复杂/扩展场景） #

如果以后你的流程可能增加更多步骤（比如失败重试、分支逻辑），用Step Functions来编排会更易维护，它天生支持按顺序执行任务，还能可视化流程。

1. 创建状态机 #

状态机的定义示例（JSON格式），这里定义两个任务，依次执行：

{
  "Comment": "按顺序执行两个Lambda",
  "StartAt": "第一个Lambda任务",
  "States": {
    "第一个Lambda任务": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:你的区域:你的账号ID:function:第一个Lambda的函数名",
      "Next": "第二个Lambda任务"
    },
    "第二个Lambda任务": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:你的区域:你的账号ID:function:第二个Lambda的函数名",
      "End": true
    }
  }
}

• 第一个Lambda执行完后，会自动把输出作为输入传给第二个Lambda，不需要手动调用。
• 如果需要自定义传递的数据，可以在状态机里用Parameters字段来映射。

2. 触发与获取结果 #

• 你可以直接把Step Functions作为流程入口，比如用API Gateway、S3事件等触发状态机。
• 如果一定要从第一个Lambda触发状态机，同样用boto3调用Step Functions的start_execution方法，之后可以用describe_execution获取执行结果。

关键注意事项 #

• Payload大小限制：Lambda的调用Payload最大是6MB，如果要传的数据超过这个大小，建议把数据存在S3，然后传递S3的路径给第二个Lambda。
• 错误处理：同步调用时要捕获调用失败的异常（比如Lambda执行超时、权限错误），可以加重试逻辑；Step Functions自带重试和错误处理机制，更省心。
• 异步vs同步：如果不需要等待第二个Lambda的结果，也可以用InvocationType='Event'做异步调用，但这样就无法直接获取响应，适合不需要依赖结果的场景。

内容的提问来源于stack exchange，提问作者ABCD