#aws-lambda #amazon-sqs #lambda #aws #event-processing

lambda_sqs

处理 SQS 事件,并提供用于处理的您类型的一个 vec

9 个版本

新版本 0.2.7 2024 年 8 月 3 日
0.2.6 2024 年 7 月 27 日
0.2.4 2023 年 1 月 22 日
0.2.3 2022 年 5 月 14 日
0.1.0 2021 年 9 月 16 日

#456网页编程

Download history 117/week @ 2024-04-14 92/week @ 2024-04-21 151/week @ 2024-04-28 120/week @ 2024-05-05 67/week @ 2024-05-12 36/week @ 2024-05-19 47/week @ 2024-05-26 73/week @ 2024-06-02 63/week @ 2024-06-09 83/week @ 2024-06-16 59/week @ 2024-06-23 190/week @ 2024-06-30 212/week @ 2024-07-07 170/week @ 2024-07-14 268/week @ 2024-07-21 347/week @ 2024-07-28

1,010 每月下载量

MIT/Apache

9KB
57 代码行

Rust 库 lambda_sqs

Crates.io MIT licensed Build Status Rust 1.65+ FOSSA Status Docs BuyMeaCoffee GitHubSponsors

专门化的 lambda_runtime 以接受和处理 SQS 事件。

SQS 事件

SQS 将事件批量发送到 lambda 函数(通常,这让我感到惊讶)。这个软件包提供了一个 lambda_runtime 实现,它期望接收一个[SqsEvent]类型的消息批次,并提供了一个将事件批次转换为您的 Struct 向量的方法。

使用方法

要使用此软件包,请在 Cargo.toml 中添加依赖项。

[dependencies]
lambda_sqs = " 0.2.7"

示例

use your_module::YourStruct;
use lambda_sqs::{handler_fn, Context, Error};
use lambda_sqs::SqsEvent;
#[tokio::main]
async fn main() -> Result<(), Error> {
    lambda_sqs::run(handler_fn(my_handler)).await?;
    Ok(())
}
pub async fn my_handler(e: SqsEvent, c: Context) -> Result<(), Error> {
    let events: Vec<YourStruct> = e.into_t();
#   // Process events
#   Ok(())
 }

许可证

根据您的选择,受以下许可证之一保护:

贡献

除非您明确声明,否则根据 Apache-2.0 许可证定义的,您有意提交的任何贡献,均应作为上述双许可,没有任何附加条款或条件。

依赖项

~7–16MB
~203K SLoC