xt-oss 0.5.7

Aliyun OSS SDK
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! `cargo run --example api_object_stand_put -q`
//!
//! DeleteMultipleObjects接口用于删除同一个存储空间`Bucket`中的多个文件`Object`
//!
//! - [official docs](https://help.aliyun.com/zh/oss/developer-reference/deletemultipleobjects)
//! - [xtoss example](https://github.com/isme-sun/xt_oss/blob/main/examples/api_object_stand_mutil_del.rs)
use std::{env, fs::File, io::Read, process};

use xt_oss::{
    oss::entities::{ObjectACL, StorageClass},
    prelude::*,
};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    dotenv::dotenv().ok();
    // 获取配置选项和 OSS 客户端
    let options = util::options_from_env();
    let client = oss::Client::new(options);
    // 目标文件
    let target_file = {
        let mut target_file = env::current_dir()?;
        // ["examples", "samples", "zip", "ZIPFile_10mbmb.zip"]
        ["assets", "samples", "index.html"]
            .iter()
            .for_each(|e| {
                target_file.push(e);
            });
        target_file.display().to_string()
    };
    // md5值
    let content_md5 = util::oss_file_md5(&target_file)?;
    // 获得mime
    let content_type = {
        let mime = mime_guess::from_path(&target_file).first().unwrap();
        &mime.to_string()[..]
    };
    // 获取内容
    let content = {
        let mut current_file = File::open(&target_file)?;
        let mut content = vec![];
        current_file.read_to_end(&mut content)?;
        oss::Bytes::from(content)
    };

    // 上传文件到 OSS
    let resp = client
        // .PutObject("tmp/test.zip")
        .PutObject("index.html")
        .with_object_acl(ObjectACL::PublicRead)
        .with_content_type(content_type)
        .with_storage_class(StorageClass::Standard)
        .with_content(content)
        .with_content_md5(&content_md5)
        .with_oss_tagging(vec![("k100", "v100"), ("k200", "v200")])
        // .with_timeout(120)
        .execute()
        .await
        .unwrap_or_else(|error| {
            eprint!("reqwest error: {}", error);
            process::exit(-1);
        });

    // 处理响应结果
    match resp {
        Ok(data) => println!("{:#?}", data.headers()),
        Err(message) => println!("{:#?}", message.content()),
    }

    Ok(())
}