aliyun-oss-client

aliyun OSS 的一个客户端

最开始的时候，是作为一个 rust 练手项目，渐渐的现在越来越完善了，包含了 rust 的 struct,enum, async, trait features 等特性， 以及自定义 error 类，同时也包含完整的的测试用例

使用方法

1. 在自己的项目里添加如下依赖项 (项目遵循语义化版本规则，请放心使用)

[dependencies] aliyun-oss-client = "^0.7"

1. 打开你需要使用 oss 的文件，在里面添加如下内容，即可使用：

``` // dotenv 是用于获取配置信息的，可以不使用 extern crate dotenv; use dotenv::dotenv; use std::env;

// 需要提供四个配置信息 let keyid = env::var("ALIYUNKEYID").unwrap(); let keysecret = env::var("ALIYUNKEYSECRET").unwrap(); let endpoint = env::var("ALIYUNENDPOINT").unwrap(); let bucket = env::var("ALIYUNBUCKET").unwrap();

// 获取客户端实例 let client = aliyunossclient::client(&keyid,&keysecret, &endpoint, &bucket); ```

异步

查询所有的 bucket 信息

let response = client.get_bucket_list().await.unwrap(); println!("buckets list: {:?}", response);

获取 bucket 信息

let response = client.get_bucket_info().await.unwrap(); println!("bucket info: {:?}", response);

查询当前 bucket 中的 object 列表

let query: HashMap<String,String> = HashMap::new(); let response = client.get_object_list(query).await.unwrap(); println!("objects list: {:?}", response);

也可以使用 bucket struct 查询 object 列表

``` let mut query:HashMap = HashMap::new(); query.insert("max-keys".tostring(), "5".tostring()); query.insert("prefix".tostring(), "babel".tostring());

let result = client.getbucketinfo().await.unwrap().getobjectlist(query).await.unwrap();

println!("object list : {:?}", result);

```

上传文件

``` client.put_file("examples/bg2015071010.png", "examples/bg2015071010.png").expect("上传失败");

// or 上传文件内容 let mut filecontent = Vec::new(); std::fs::File::open(filename) .expect("open file failed").readtoend(&mut filecontent) .expect("readtoend failed"); client.putcontent(&file_content, "examples/bg2015071010.png").await.expect("上传失败"); ```

删除文件

client.delete_object("examples/bg2015071010.png").await.unwrap();

同步（阻塞模式）

如需使用，需要启用 blocking 特征

查询所有的 bucket 信息

let response = client.blocking_get_bucket_list().unwrap(); println!("buckets list: {:?}", response);

获取 bucket 信息

let response = client.blocking_get_bucket_info().unwrap(); println!("bucket info: {:?}", response);

查询当前 bucket 中的 object 列表

let query: HashMap<String,String> = HashMap::new(); let response = client.blocking_get_object_list(query).unwrap(); println!("objects list: {:?}", response);

也可以使用 bucket struct 查询 object 列表

``` let mut query:HashMap = HashMap::new(); query.insert("max-keys".tostring(), "5".tostring()); query.insert("prefix".tostring(), "babel".tostring());

let result = client.blockinggetbucketinfo().unwrap().blockinggetobjectlist(query).unwrap();

println!("object list : {:?}", result);

// 翻页功能 获取下一页数据 println!("next object list: {:?}", result.next().unwrap()); ```

上传文件

``` client.blockingputfile("examples/bg2015071010.png", "examples/bg2015071010.png").expect("上传失败");

// or 上传文件内容 let mut filecontent = Vec::new(); std::fs::File::open(filename) .expect("open file failed").readtoend(&mut filecontent) .expect("readtoend failed"); client.blockingputcontent(&filecontent, "examples/bg2015071010.png").expect("上传失败"); ```

删除文件

``` client.blockingdeleteobject("examples/bg2015071010.png").unwrap();

```

与 官方 client 对比

• 完整的测试用例
• 单一入口，避免泛引入导致意外的命名冲突
• 链式调用
• 对公共的参数进行了封装，每次调用的时候，只需要传递业务参数即可
• 默认支持异步调用，可选的支持同步方式调用
• 支持内置的 object bucket 等结构体
• 支持导出数据到自定义的 object bucket 结构体