#round-robin #service #remote #celery #async #task #integration

tourniquet-celery

针对远程服务的异步本地轮询管理器。celery 集成。

3 个不稳定版本

0.2.0 2023 年 5 月 10 日
0.1.1 2022 年 1 月 5 日
0.1.0 2022 年 1 月 4 日

异步 中排名第 1140

Download history • Rust 包仓库 96/week @ 2024-03-17 • Rust 包仓库 85/week @ 2024-03-24 • Rust 包仓库 102/week @ 2024-03-31 • Rust 包仓库 88/week @ 2024-04-07 • Rust 包仓库 73/week @ 2024-04-14 • Rust 包仓库 4/week @ 2024-04-21 • Rust 包仓库 9/week @ 2024-04-28 • Rust 包仓库 22/week @ 2024-05-05 • Rust 包仓库 36/week @ 2024-05-12 • Rust 包仓库 48/week @ 2024-05-19 • Rust 包仓库 46/week @ 2024-05-26 • Rust 包仓库 61/week @ 2024-06-02 • Rust 包仓库 32/week @ 2024-06-09 • Rust 包仓库 26/week @ 2024-06-16 • Rust 包仓库 150/week @ 2024-06-23 • Rust 包仓库 47/week @ 2024-06-30 • Rust 包仓库

每月下载量 256

MIT 许可协议 MIT

28KB
374

tourniquet-celery

Tourniquetcelery 库的集成。

示例

#
#[celery::task]
async fn do_work(work: String) -> TaskResult<()> {
    // Some work
    Ok(())
}

let rr = RoundRobin::new(
    vec!["amqp://rabbit01:5672/".to_owned(), "amqp://rabbit02:5672".to_owned()],
    CeleryConnector { name: "rr", routes: &[("*", "my_route")], ..Default::default() },
);

rr.send_task(|| do_work::new(work.clone())).await.expect("Failed to send task");

许可协议:MIT


lib.rs:

Tourniquetcelery 库的集成。

示例

#
#[celery::task]
async fn do_work(work: String) -> TaskResult<()> {
    // Some work
    Ok(())
}

let rr = RoundRobin::new(
    vec!["amqp://rabbit01:5672/".to_owned(), "amqp://rabbit02:5672".to_owned()],
    CeleryConnector { name: "rr", routes: &[("*", "my_route")], ..Default::default() },
);

rr.send_task(|| do_work::new(work.clone())).await.expect("Failed to send task");

依赖项

~18–32MB
~501K SLoC