#adventure #rusoto #requests #api-bindings #rusoto-sqs

adventure-rusoto-sqs

rusoto_sqs的冒险之旅

2个不稳定版本

0.4.0 2020年1月8日
0.3.0 2019年7月11日

#8 in #adventure

MIT/Apache

51KB
1.5K SLoC

Adventure

docs.rs

为Web请求提供通用工具,如指数退避和分页。

示例

use std::sync::Arc;

use adventure::prelude::*;
use futures::prelude::*;

use adventure_rusoto_ecs::AwsEcs;
use rusoto_core::Region;
use rusoto_ecs::{EcsClient, ListServicesRequest};

fn main() {
    let client = EcsClient::new(Region::default());
    let req = ListServicesRequest {
        cluster: Some("MyEcsCluster".to_owned()),
        ..Default::default()
    };

    tokio::run(

        // prepare a request
        AwsEcs::from(req)
            // backoff if server error is occured
            .retry()
            // repeat to retrieve all results
            .paginate(Arc::new(client))

            // compatible with futures
            .for_each(|page| {
                for service in page.service_arns.unwrap_or_else(Vec::new) {
                    println!("{}", service);
                }
                Ok(())
            })
            .or_else(|err| {
                eprintln!("Error occured: {}", err);
                Ok(())
            }),
    );
}

lib.rs:

一个概念验证包,提供rusoto_sqs中类型的特质实现,以便与adventure一起使用。

示例

依赖项

~16–31MB
~507K SLoC