本章将讨论如何将 B2 集成到 Rust中。
由于 B2 兼容 S3,所以完全可以使用 S3 相关的 crate,本专题将使用rust-s3
依赖
[dependencies]
rust-s3 = "0.33"
tokio = { version = "1", features = ["full"]}
rust-s3
即是我们需要的依赖项- 由于我们使用的是
tokio
异步库,所以加上其依赖
接下来,我们看一下它的基本操作。
授权
首先,你需要按照《使用 B2 存储》章节所述,注册并添加应用程序密钥。
access_key
:对应B2应用程序的keyID
secret_key
:对应B2应用程序的applicationKey
所以,它最终是这样的:
let cred = s3::creds::Credentials {
access_key: Some("你的keyID".to_string()),
secret_key: Some("你的applicationKey".to_string()),
session_token: None,
security_token: None,
expiration: None,
};
实例化桶
授权是实例化桶时的参数之一,它需要以下参数:
- 桶名:你创建的应用程序密钥对应的桶名称
- 区域:该桶的 Endpoint
- 授权:上一步骤创建的授权
let bucket = s3::Bucket::new("桶名称", "区域".parse().unwrap, cred).unwrap();
上传文件
上传文件常用的有两个方法:
put_object(远程路径, 数据)
put_object_with_content_type(远程路径, 数据, 内容类型)
两者区别在于,无论什么类型的文件,put_object()
的*content type(内容类型)*均为 application/octet-stream
,而 put_object_with_content_type()
可以手动为不同的文件指定对应的内容类型。
let path = "axum.rs.file";
let data = "axum中文网:axum.rs".as_bytes();
let resp = bucket.put_object(path, data).await.unwrap();
assert_eq!(resp.status_code(), 200);
println!("{:?}", resp);
let resp = bucket.put_object_with_content_type(path, data, "plain/text").await.unwrap();
assert_eq!(resp.status_code(), 200);
println!("{:?}", resp);
下载文件
通过 get_object_to_writer()
可以下载文件并写入到指定目标。
let mut output_file = tokio::fs::File::create("/tmp/axum.rs.file").await.expect("创建文件失败");
let status_code = bucket.get_object_to_writer("axum.rs.file", &mut output_file).await?
删除文件
使用 delete_object()
可以删除指定的文件。