Struct ObsClient 

pub struct ObsClient {
    pub endpoint: String,
    pub ak: String,
    pub sk: String,
    pub bucket: String,
}

华为云OBS客户端

Fields

endpoint: String

ak: String

sk: String

bucket: String

Implementations

impl ObsClient

pub async fn list( &self, prefix: &str, is_all: bool, ) -> Result<Vec<ObjectMeta>, ObsError>

列举指定前缀开头的所有对象元数据，方法内部会构造http请求：

GET / HTTP/1.1
Host: bucketname.obs.cn-north-4.myhuaweicloud.com
Date: date
Authorization: authorization

参数

prefix - 对象名前缀 is_all - 是否列举所有满足prefix的对象，true表示分页查询所有对象，false表示只查询第一页（最多1000个）

pub async fn upload_object( &self, obj_key: &str, data: Vec<u8>, ) -> Result<(), ObsError>

上传对象

方法内部构建请求

PUT /object01 HTTP/1.1
User-Agent: curl/7.29.0
Host: examplebucket.obs.cn-north-4.myhuaweicloud.com
Accept: */*
Date: WED, 01 Jul 2015 04:11:15 GMT
Authorization: OBS H4IPJX0TQTHTHEBQQCEC:gYqplLq30dEX7GMi2qFWyjdFsyw=
Content-Length: 10240
Expect: 100-continue
 
[1024 Byte data content]

pub async fn upload_file( &self, obj_key: &str, file_path: &str, ) -> Result<(), ObsError>

上传文件

pub async fn upload_files( &self, files: Vec<(&str, &str)>, ) -> Vec<Result<(), ObsError>>

批量上传文件

使用异步并发上传多个文件，并发数不超过32个

参数

files - 文件列表，每个元素是(obj_key, file_path)元组

返回

返回一个Vec<Result<(), ObsError>>，每个元素对应一个文件的上传结果

pub async fn download_object(&self, obj_key: &str) -> Result<Vec<u8>, ObsError>

下载对象，方法内部会构造http请求：

GET /{obj_key} HTTP/1.1
Host: {bucket}.obs.cn-north-4.myhuaweicloud.com
Date: {date}

pub async fn delete_object(&self, obj_key: &str) -> Result<(), ObsError>

删除obs上的对象

pub async fn download_file( &self, obj_key: &str, file_path: &str, overwrite: bool, ) -> Result<(), ObsError>

下载文件，并指定本地保存用的文件路径

参数

overwrite - 是否覆盖，true，当文件存在时，覆盖文件，false，当文件存在时，不覆盖文件

pub async fn download_files( &self, files: Vec<(&str, &str, bool)>, ) -> Vec<Result<(), ObsError>>

批量下载文件

使用异步并发下载多个文件，并发数不超过32个

参数

files - 文件列表，每个元素是(obj_key, file_path, overwrite)元组

返回

返回一个Vec<Result<(), ObsError>>，每个元素对应一个文件的下载结果

pub fn url_sign(&self, url_str: &str) -> Result<String, ObsError>