需要判断bucket中是否存在某个object应该怎么做

[itisl2220]

需要判断bucket中是否存在某个object应该怎么做， 好像没有实现head_object方法

[tu6ge]

看起来是一个新特性，在尝试解决的时候，却暴露了新的问题，临时可以使用如下代码进行判断

use std::{env, sync::Arc};

use aliyun_oss_client::{
    auth::{AuthBuilder, AuthGetHeader},
    builder::ArcPointer,
    config::{ObjectBase, ObjectPath, UrlObjectPath},
    errors::OssError,
    types::CanonicalizedResource,
    Client,
};
use chrono::Utc;
use dotenv::dotenv;
use http::HeaderMap;

#[tokio::main]
pub async fn main() -> Result<(), OssError> {
    dotenv().ok();

    let key_id = env::var("ALIYUN_KEY_ID").map_err(OssError::from)?;
    let key_secret = env::var("ALIYUN_KEY_SECRET").map_err(OssError::from)?;

    let client = Client::from_env().unwrap();

    let path = ObjectPath::new("9AB932LY.jpeg");

    let mut url = client.get_bucket_url();
    url.set_object_path(&path);

    let object_base = ObjectBase::<ArcPointer>::new(Arc::new(client.get_bucket_base()), path);

    let resource = CanonicalizedResource::from_object(object_base, []);

    let mut headers = HeaderMap::new();

    headers.insert(
        "If-Unmodified-Since",
        "Sat, 01 Jan 2022 18:01:01 GMT".try_into().unwrap(),
    );

    let reqw_header = AuthBuilder::default()
        .key(key_id.into())
        .secret(key_secret.into())
        .verb(&"HEAD".into())
        .date(Utc::now().into())
        .canonicalized_resource(resource)
        .with_headers(Some(headers))
        .get_headers()
        .unwrap();

    let client = reqwest::Client::new();
    let response = client.head(url).headers(reqw_header).send().await?;

    println!("result status: {:?}", response.status());

    Ok(())
}

[itisl2220]

非常感谢，后续是否考虑完善这些功能

[tu6ge]

问题没有解决呢，先开着

[tu6ge]

刚刚发布了新版本，有更方便的方式可以做到这个

use aliyun_oss_client::{errors::OssError, file::AlignBuilder, Client, Method};
use dotenv::dotenv;

#[tokio::main]
pub async fn main() -> Result<(), OssError> {
    dotenv().ok();

    let client = Client::from_env().unwrap();

    let (url, resource) = client.get_object_base("9AB932LY.jpeg").get_url_resource([]);

    let headers = vec![(
        "If-Unmodified-Since".parse().unwrap(),
        "Sat, 01 Jan 2022 18:01:01 GMT".parse().unwrap(),
    )];

    let builder = client.builder_with_header(Method::HEAD, url, resource, headers)?;

    let response = builder.send().await?;

    println!("status: {:?}", response.status());

    Ok(())
}

[itisl2220]

好的，谢谢

[asins]

因为你之前没实现head_object，我是用以下方式判断object是否存在的，有现在的方式就方便多了嘛

    // 参数说明：https://help.aliyun.com/document_detail/187544.html
    let mut query = Query::new();
    query.insert("prefix", oss_dir.to_string());
    query.insert("max-keys", "1");
    match client.get_object_list(query).await {
        Ok(object_list) => {
            // log::trace!("object list: {:#?}", object_list);
            let key_count = object_list.key_count();
            Ok(key_count > &0)
        }
        Err(e) => Err(anyhow!(e.to_string())),
    }

我现在需要改写成这样：

    let (url, resource) = client.get_object_base(oss_dir).get_url_resource([]);
    let headers = vec![];
    let builder = client.builder_with_header(Method::HEAD, url, resource, headers)?;

    let response = builder.send().await?;
    let status = response.status();
    let sc200 = StatusCode::from_u16(200)?;
    let sc300 = StatusCode::from_u16(300)?;

    Ok(status >= sc200 && status < sc300)

[tu6ge]

其实还可以改成这样：

    let (url, resource) = client.get_object_base(oss_dir).get_url_resource([]);
    let headers = vec![];
    let builder = client.builder_with_header(Method::HEAD, url, resource, headers)?;

    let response = builder.send().await?;
    let status = response.status();
-   let sc200 = StatusCode::from_u16(200)?;
-   let sc300 = StatusCode::from_u16(300)?;

-   Ok(status >= sc200 && status < sc300)
+   Ok(status.is_success())

[asins]

可以这样写的话就简洁很多噢