s3-wire 0.2.0

An async, streaming S3-compatible client for Rust
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
30
31

//! Upload a file through the bounded managed multipart API.

use std::env;
use std::error::Error;
use std::time::Duration;

use s3_wire::{DeleteObjectRequest, ManagedMultipartUploadRequest, MultipartOptions, ObjectKey};

mod common;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let client = common::client_from_env()?;
    let source = common::required_env("S3_FILE")?;
    let key = ObjectKey::new(
        env::var("S3_KEY").unwrap_or_else(|_| "examples/multipart-upload.bin".to_owned()),
    )?;
    let options = MultipartOptions::new(8 * 1024 * 1024, 4)?
        .with_transfer_timeout(Duration::from_secs(15 * 60))?;

    client
        .multipart_upload(
            ManagedMultipartUploadRequest::from_path(key.clone(), source)
                .with_content_type("application/octet-stream")
                .with_options(options),
        )
        .await?;

    client.delete_object(DeleteObjectRequest::new(key)).await?;
    Ok(())
}