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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
//! `cargo run --example aa_del_object_all -q`
//!
//! 这段代码是一个示例程序，用于删除指定存储桶中的所有对象。它演示了如何使用 Rust 语言与 OSS 进行对象管理操作，
//! 并使用异步编程模型来提高效率。
//!
//! 以下是代码的主要逻辑：
//!
//! 1. 导入所需的库和模块。
//! 2. 定义了一个异步函数 del_all()，用于删除指定存储桶中的所有对象。
//! 3. 在 main() 函数中，先打印警告信息，然后提示用户是否继续操作。
//! 4. 用户输入 Y 表示继续操作，调用 del_all() 函数进行对象删除操作。
//! 5. 用户输入 n 表示取消操作，程序结束。
//! 6. 用户输入其他值时，提示用户输入 Y 或 n。
//! 7. del_all() 函数中，使用循环列出存储桶中的所有对象，并发起删除操作。删除操作使用异步任务进行并行处理。
//! 8. 每次删除操作完成后，输出相应的结果信息。
//!
//! -- ChatGPT3.5 解读
use dotenv;
use futures::future::join_all;
use std::io::{self, Write};
use std::{process, sync::Arc};
use xt_oss::prelude::*;
async fn del_all() -> Result<(), Box<dyn std::error::Error>> {
dotenv::dotenv().ok();
let options = util::options_from_env();
let client = Arc::new(oss::Client::new(options));
loop {
match client
.ListObjectsV2()
.with_max_keys(5)
.execute()
.await
.unwrap_or_else(|error| {
println!("reqwest error: {}", error);
process::exit(-1);
}) {
Ok(data) => {
let data = data.content();
if let Some(objects) = data.contents {
let tasks = objects.into_iter().map(|object| {
let client = Arc::clone(&client);
async move {
let result = client.DeleteObject(object.key.as_str()).execute().await;
match result {
Ok(Ok(_)) => println!("delete object key: {}", object.key),
Ok(Err(message)) => println!("{}", message.content()),
Err(error) => println!("reqwest error: {}", error),
}
}
});
join_all(tasks).await;
} else {
println!("bucket file clean");
return Ok(());
}
}
Err(message) => {
println!("oss error: {}", message.content())
}
}
}
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + 'static>> {
println!("警告：后续操作可能存在危险！");
loop {
print!("是否继续操作?(Y/n):");
io::stdout().flush().unwrap();
let mut input = String::new();
io::stdin().read_line(&mut input).unwrap();
match input.trim().to_uppercase().as_str() {
"Y" => {
println!("继续运行...");
del_all().await?;
break;
}
"n" => {
println!("操作已取消。");
break;
}
_ => {
println!("无效的输入，请输入 Y 或 n。");
}
}
}
Ok(())
}