Rusoto S3 从 S3 读取对象

Question

抱歉，如果这是一个愚蠢的问题，我对使用 rust 还很陌生，我很难弄清楚如何使用 rusoto 库从 s3 读取对象。

https://rusoto.github.io/rusoto/rusoto_s3/

到目前为止我已经锻炼了这么多：

let mut get_object_request = rusoto_s3::GetObjectRequest::default();
get_object_request.bucket = bucket.to_owned();
get_object_request.key = object_id.to_owned();

let resp = client.get_object(get_object_request)
    .await
    .map_err(|_| {
        FailedToParseFile(format!(
            "Failed to retrieve file from s3, bucket: {}, object id: {}",
            bucket, object_id
        ))
    })?;

let mut resp_body = match resp.body {
    Some(body) => {body}
    None => { return Err(ClientError::FailedToObtainConfiguredFile(
        format!("Failed to retrieve the file: {} in {}", object_id, bucket)
    ))}
};

但是我不知道如何将由此返回的流式主体转换为可用的字符串。我已经尝试了一些方法来让它工作，但 none 似乎对我有用。

let mut byte_buffer = String::new();
    resp_body.into_blocking_read()
        .read_to_string(&mut byte_buffer)
        .map_err(|_| {
            FailedToParseFile(format!(
                "Failed to parse the received file, bucket: {}, object id: {}",
                bucket, object_id
            ))
        })?;

    let resp_body_bytes = byte_buffer.into_bytes();

由于我正在使用 tokio（rocket），这个阻塞队列对我来说似乎不是一个选项，导致它在尝试阻塞异步线程时出现恐慌。我开始研究方法 'into_async_read()' 而不是阻塞，但我对此也不熟悉，并且似乎正在努力按预期使用它，这开始看起来很复杂，也许我遗漏了一些东西，对此有任何帮助将不胜感激。

Answer 1

    let mut byte_buffer = String::new();
    Pin::new(&mut resp_body.into_async_read())
            .read_to_string(&mut byte_buffer)
            .await;

这实际上似乎做了我需要它做的事情，搞砸了我没有意识到 .read_to_string(&mut byte_buffer) 的结果可以等待以填充提供的缓冲区。

Rusoto S3 从 S3 读取对象

Rusoto S3 reading object from S3

amazon-s3

rust

rusoto

rust-tokio