lakestream 0.0.3

Portable file-utility for object-stores
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use log::info;

use super::bucket::S3Bucket;
use super::client_headers::Headers;
use super::list::create_s3_client;
use super::request_handler::http_get_with_redirect_handling;
use crate::{LakestreamError, ObjectStoreTrait};

pub async fn get_object(
    s3_bucket: &S3Bucket,
    object_key: &str,
    data: &mut Vec<u8>,
) -> Result<(), LakestreamError> {
    let s3_client =
        create_s3_client(s3_bucket.config(), Some(s3_bucket.name()));

    info!("Getting object: {}", object_key);
    let (response_body, _updated_s3_client) =
        http_get_with_redirect_handling(&s3_client, |s3_client| {
            s3_client.generate_get_object_headers(object_key)
        })
        .await?;

    // Write response body directly into the provided Vec<u8>
    data.clear();
    data.extend_from_slice(response_body.as_bytes());

    Ok(())
}