AWS Lambda能否通过SDK借助Event Bridge API Destinations调用REST API？

完全可行。你可以通过AWS SDK（如boto3）直接调用EventBridge的API来触发预配置好的API Destinations，有两种常用实现方式：

方法1：直接调用API Destination（推荐） #

通过EventBridge SDK的invoke_api_destination方法，直接触发已配置的API Destination，无需经过事件总线或规则中转，适合同步调用场景。

Python示例代码 #

import boto3

def lambda_handler(event, context):
    eventbridge = boto3.client('events')
    
    # 替换为你的API Destination ARN
    api_dest_arn = 'arn:aws:events:us-east-1:123456789012:api-destination/YourApiDestName'
    
    # 构造第三方API所需的请求体
    request_body = {
        "param1": "test-value-1",
        "param2": "test-value-2"
    }
    
    try:
        response = eventbridge.invoke_api_destination(
            ApiDestinationArn=api_dest_arn,
            HttpMethod='POST',  # 需匹配API Destination配置的HTTP方法
            Body=bytes(str(request_body), 'utf-8'),
            Headers={'Content-Type': 'application/json'}
        )
        print(f"API调用成功，响应状态码: {response['StatusCode']}")
        return {'statusCode': 200, 'body': f"调用成功，状态码: {response['StatusCode']}"}
    except Exception as e:
        print(f"调用失败: {str(e)}")
        return {'statusCode': 500, 'body': f"调用失败: {str(e)}"}

所需IAM权限 #

给Lambda执行角色添加以下权限策略：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "events:InvokeApiDestination",
            "Resource": "arn:aws:events:your-region:your-account-id:api-destination/YourApiDestName"
        }
    ]
}

方法2：通过EventBridge规则间接调用 #

先在EventBridge中创建规则，将API Destination设为规则目标；然后Lambda向对应事件总线发送事件，触发规则执行API调用。这种方式适合需要利用EventBridge内置的重试、死信队列等特性的场景。

Python示例代码 #

import boto3
import json

def lambda_handler(event, context):
    eventbridge = boto3.client('events')
    
    # 替换为你的事件总线ARN（默认总线可用默认ARN）
    event_bus_arn = 'arn:aws:events:us-east-1:123456789012:event-bus/default'
    # 需匹配你EventBridge规则定义的source和detail-type
    event_source = "my.lambda.service"
    event_detail_type = "ThirdPartyApiRequest"
    
    # 构造事件内容
    event_detail = {
        "param1": "test-value-1",
        "param2": "test-value-2"
    }
    
    try:
        response = eventbridge.put_events(
            Entries=[
                {
                    'Source': event_source,
                    'DetailType': event_detail_type,
                    'Detail': json.dumps(event_detail),
                    'EventBusName': event_bus_arn
                }
            ]
        )
        print(f"事件发送成功: {response}")
        return {'statusCode': 200, 'body': "事件已发送，将触发API调用"}
    except Exception as e:
        print(f"事件发送失败: {str(e)}")
        return {'statusCode': 500, 'body': f"事件发送失败: {str(e)}"}

所需IAM权限 #

给Lambda执行角色添加以下权限策略：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "events:PutEvents",
            "Resource": "arn:aws:events:your-region:your-account-id:event-bus/default"
        }
    ]
}

注意事项 #

1. 确保你已经在AWS控制台完成API Destination的配置（包括第三方API端点、认证方式、HTTP方法等）
2. 直接调用方式性能更高，无事件总线中转延迟；规则方式则能利用EventBridge的重试、错误处理机制
3. 调用时需保证API Destination的配置与代码中的HTTP方法、请求头/体格式匹配

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