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) -> Result<Vec<ObjectMeta>, ObsError>

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

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

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 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 fn url_sign(&self, url_str: &str) -> Result<String, ObsError>