OSS-Rust-SDK

It's an unofficial Rust port for https://github.com/aliyun/aliyun-oss-cpp-sdk, just implement core APIs of https://help.aliyun.com/document_detail/31977.html, everyone is welcome to submit a PR to implement which interface you need.

Getting Started

List your_Buckets

```rust use ossrustsdk::prelude::*; let ossinstance = OSS::new("yourAccessKeyId", "yourAccessKeySecret", "yourEndpoint", "yourBucket"); let listbuckets = ossinstance.listbucket(None).unwrap();

let id = listbuckets.id(); let yourBuckets = listbuckets.buckets(); let yourBucketnames: Vec<&str> = yourBuckets.iter().map(|obj| obj.name()).collect(); ```

Get Object

```rust use ossrustsdk::prelude::*; use std::collections::HashMap;

let ossinstance = OSS::new("yourAccessKeyId", "yourAccessKeySecret", "yourEndpoint", "your_Bucket");

/// if have extra header let mut extraheader = HashMap::new(); extraheader.insert("content-type", "text/plain"); /// if have osssubresource let mut osssubresource = HashMap::new(); osssubresource.insert("acl", None); osssubresource.insert("response-content-type", Some("ContentType"));

let result = ossinstance.getobject("object", extarheader, osssubresource); /// or you may just get object /// let result = ossinstance.getobject("object", None, None); asserteq!(result.is_ok(), true); let buffer = result.unwrap(); ```

Get Object async

```rust use ossrustsdk::oss::OSS; use ossrustsdk::async_object::*; use tokio::runtime::Runtime;

fn asyncgetobjectdemo() { let ossinstance = OSS::new("yourAccessKeyId", "yourAccessKeySecret", "yourEndpoint", "yourBucket");

let mut rt = Runtime::new().expect("failed to start runtime");

rt.block_on(async move {
    let _ = oss_instance.get_object("objectName", None::<HashMap<&str, &str>>, None).await.unwrap();
    println!("buffer = {:?}", String::from_utf8(result.unwrap()));
});

}

or

async fn asyncgetobjectdemo() -> Reuslt { let ossinstance = OSS::new("yourAccessKeyId", "yourAccessKeySecret", "yourEndpoint", "yourBucket"); let buf = ossinstance.asyncgetobject("objectName", None, None).await?; String::fromutf8(buf)? } ```

Put Object by file

rust use oss_rust_sdk::prelude::*; let filename = "filename"; let oss_instance = OSS::new("your_AccessKeyId", "your_AccessKeySecret", "your_Endpoint", "your_Bucket"); let result = oss_instance.put_object_from_file(filename, "object", None, None); assert_eq!(result.is_ok(), true)

Put Ojbect by buffer

rust let buffer = "some thing you want put to oss"; let oss_instance = OSS::new("your_AccessKeyId", "your_AccessKeySecret", "your_Endpoint", "your_Bucket"); let result = oss_instance.put_object_from_buffer(buffer.as_bytes(), "object", None, None); assert_eq!(result.is_ok(), true)

Pub Object Async

```rust use ossrustsdk::oss::OSS; use ossrustsdk::async_object::*;

let buffer = "test async put object from buffer"; let ossinstance = OSS::new("yourAccessKeyId", "yourAccessKeySecret", "yourEndpoint", "your_Bucket"); let mut headers = HashMap::new(); headers.insert("content-type", "text/plain");

ossinstance.putobject(buffer.asbytes(),"yourobject_name", headers,None).await?; ```

Copy Object

rust use oss_rust_sdk::prelude::*; let oss_instance = OSS::new("your_AccessKeyId", "your_AccessKeySecret", "your_Endpoint", "your_Bucket"); let result = oss_instance.copy_object_from_object("src_object", "dest_object", None, None); assert_eq!(result.is_ok(), true)

Delete Ojbect

rust use oss_rust_sdk::prelude::*; let oss_instance = OSS::new("your_AccessKeyId", "your_AccessKeySecret", "your_Endpoint", "your_Bucket"); let result = oss_instance.delete_object("object"); assert_eq!(result.is_ok(), true)

You can use oss_instance.set_bucket("your_Bucket") to change specific bucket after create the oss instance.

License

• Apache License 2.0.