Rusoto S3从S3读取对象

Question

很抱歉，如果这是一个愚蠢的问题，我已经足够使用生锈了，而且我很难弄清楚如何使用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)
    ))}
};

但是，我不知道如何将从中返回的流体转换为可用的字符串。我试过几样东西来让它起作用，但似乎没有一件对我有用。

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 (火箭)，这个阻塞队列对我来说似乎不是一个选项，它在试图阻止异步线程时会引起恐慌。我开始研究'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)的结果来填充所提供的缓冲区。