如何使用AWS SDK开发Web API实现Event Bus创建及属性更新

前置准备 #

• 配置AWS访问凭证：本地开发可以通过AWS CLI配置凭证文件，生产环境为运行Web API的AWS资源（如EC2、ECS、AppRunner等）绑定拥有以下权限的IAM角色：
  • EventBridge相关权限：events:CreateEventBus、events:PutRule、events:PutTargets、events:DeleteRule、events:RemoveTargets
  • Lambda相关权限：lambda:AddPermission、lambda:RemovePermission（用于配置EventBridge调用Lambda的权限）
• 建议将区域、资源前缀等配置项放入配置文件，避免硬编码。

C# 实现方案 #

• 首先安装依赖NuGet包：AWSSDK.EventBridge、AWSSDK.Lambda
• 核心代码示例：

using Amazon.EventBridge;
using Amazon.EventBridge.Model;
using Amazon.Lambda;
using Amazon.Lambda.Model;

// 初始化EventBridge客户端
var eventBridgeClient = new AmazonEventBridgeClient();
// 初始化Lambda客户端
var lambdaClient = new AmazonLambdaClient();

// 1. 创建自定义Event Bus
var createBusRequest = new CreateEventBusRequest
{
    Name = "your-custom-event-bus",
    Tags = new List<Tag> { new Tag { Key = "Env", Value = "Prod" } }
};
var busResponse = await eventBridgeClient.CreateEventBusAsync(createBusRequest);
var eventBusArn = busResponse.EventBusArn;

// 2. 创建/更新调度规则
var putRuleRequest = new PutRuleRequest
{
    Name = "daily-sync-rule",
    EventBusName = "your-custom-event-bus",
    // Cron表达式为UTC时区，示例为每天凌晨2点执行
    ScheduleExpression = "cron(0 2 * * ? *)",
    State = RuleState.ENABLED
};
var ruleResponse = await eventBridgeClient.PutRuleAsync(putRuleRequest);
var ruleArn = ruleResponse.RuleArn;

// 3. 给Lambda添加EventBridge调用权限
await lambdaClient.AddPermissionAsync(new AddPermissionRequest
{
    FunctionName = "your-target-lambda-name",
    StatementId = "eventbridge-invoke-perm",
    Action = "lambda:InvokeFunction",
    Principal = "events.amazonaws.com",
    SourceArn = ruleArn
});

// 4. 为规则绑定Lambda目标
var putTargetRequest = new PutTargetsRequest
{
    Rule = "daily-sync-rule",
    EventBusName = "your-custom-event-bus",
    Targets = new List<Target>
    {
        new Target
        {
            Id = "lambda-target-01",
            Arn = "arn:aws:lambda:us-east-1:1234567890:function:your-target-lambda-name"
        }
    }
};
await eventBridgeClient.PutTargetsAsync(putTargetRequest);

Python 实现方案 #

• 首先安装依赖包：boto3
• 核心代码示例：

import boto3

# 初始化客户端
event_bridge_client = boto3.client('events')
lambda_client = boto3.client('lambda')

# 1. 创建自定义Event Bus
create_bus_resp = event_bridge_client.create_event_bus(
    Name='your-custom-event-bus',
    Tags=[{'Key': 'Env', 'Value': 'Prod'}]
)
event_bus_arn = create_bus_resp['EventBusArn']

# 2. 创建/更新调度规则
put_rule_resp = event_bridge_client.put_rule(
    Name='daily-sync-rule',
    EventBusName='your-custom-event-bus',
    ScheduleExpression='cron(0 2 * * ? *)',
    State='ENABLED'
)
rule_arn = put_rule_resp['RuleArn']

# 3. 给Lambda添加EventBridge调用权限
lambda_client.add_permission(
    FunctionName='your-target-lambda-name',
    StatementId='eventbridge-invoke-perm',
    Action='lambda:InvokeFunction',
    Principal='events.amazonaws.com',
    SourceArn=rule_arn
)

# 4. 为规则绑定Lambda目标
event_bridge_client.put_targets(
    Rule='daily-sync-rule',
    EventBusName='your-custom-event-bus',
    Targets=[{
        'Id': 'lambda-target-01',
        'Arn': 'arn:aws:lambda:us-east-1:1234567890:function:your-target-lambda-name'
    }]
)

注意事项 #

• EventBridge的Cron调度表达式默认使用UTC时区，如需使用本地时区可以在规则中额外配置时区参数，或者自行做时间偏移转换。
• 每个规则默认最多绑定10个目标，超出配额可以向AWS提交工单申请提升。
• 生产环境建议为自定义Event Bus开启KMS加密，保障事件传输和存储的安全性。
• 操作资源时建议添加幂等校验，比如创建Event Bus前先调用列表查询接口判断是否已经存在，避免重复创建报错。
• 可以把上述逻辑封装到Web API的不同接口中，比如POST接口用于创建Event Bus、PUT接口用于更新规则和目标配置。

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