使用Rust实现AWS EventBridge事件发送的Hello World程序求助

需求与现有代码 #

需要构建一个Rust程序，接收JSON事件并发送到指定EventBus，同时返回"success"提示。对应的Python实现代码如下：

response = events_client.put_events(
    Entries=[{
        "Source": SRC_ARN,
        "DetailType": 'event',
        "Detail": json.dumps(payload),
        "EventBusName": DEST_ARN
    }]
)

尝试编写的Rust代码如下（存在问题）：

use aws_sdk_eventbridge as eeb;
use aws_sdk_eventbridge::types::PutEventsRequestEntry;
use json;

async fn main() -> Result<(), eeb::Error> {
    //configuring the client
    let config = aws_config::load_from_env().await;
    let client = aws_sdk_eventbridge::Client::new(&config);
    let eventjson = json::parse(r#"{"event":"test"}"#);

    //building the event
    let eeb_bus_name = "arn" //replaced my arn for privacy;
    let entry = PutEventsRequestEntry::builder()
        .source("test")
        .detail_type("test_event")
        .event_bus_name(eeb_bus_name).build();

    let resp = client.put_events().entries(entry).endpoint_id(eeb_bus_name);
    Ok(())
}

问题修正与完整代码 #

原Rust代码存在几个关键问题，以下是修正后的实现：

use aws_sdk_eventbridge as eeb;
use aws_sdk_eventbridge::types::PutEventsRequestEntry;
use serde_json; // 采用Rust生态标准的JSON处理库

async fn main() -> Result<(), eeb::Error> {
    // 加载AWS环境配置并初始化EventBridge客户端
    let config = aws_config::load_from_env().await;
    let client = eeb::Client::new(&config);

    // 序列化JSON payload为字符串（对应Python的json.dumps）
    let payload = serde_json::json!({"event": "test"});
    let detail = serde_json::to_string(&payload)?;

    // 构建EventBridge事件条目
    let eeb_bus_arn = "your-event-bus-arn"; // 替换为实际的EventBus ARN
    let entry = PutEventsRequestEntry::builder()
        .source("test") // 对应Python的Source字段
        .detail_type("test_event") // 对应Python的DetailType字段
        .detail(detail) // 设置事件详情内容
        .event_bus_name(eeb_bus_arn)
        .build()?; // 处理构建条目时的潜在错误

    // 发送事件：entries接收迭代器，将单个条目包装为数组传入
    let resp = client
        .put_events()
        .entries([entry])
        .send() // 触发请求发送
        .await?; // 等待异步响应并处理错误

    // 验证发送结果并输出提示
    if resp.failed_entry_count() == Some(0) {
        println!("success");
    } else {
        eprintln!("Failed to send event");
    }

    Ok(())
}

关键修正点说明 #

• JSON处理：改用serde_json（Rust生态标准库），确保JSON序列化逻辑与Python一致，同时处理解析/序列化的错误。
• 事件条目补全：补充了detail字段（对应Python中的Detail参数），并处理build()方法可能返回的错误。
• 请求执行：entries方法需要接收迭代器，因此将单个条目包装为数组；必须调用.send().await才能实际发送请求，原代码仅构建了请求对象未执行。
• 冗余参数移除：endpoint_id无需设置为EventBus ARN，该参数用于指定AWS终端节点ID，与EventBus名称无关。
• 结果验证：通过failed_entry_count判断事件发送状态，输出要求的"success"提示。

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