AWS Rust SDK Guide

export AWS_ENDPOINT_URL_S3="https://adapter.example.test"

use aws_config::BehaviorVersion;
use aws_sdk_s3::Client;

let shared = aws_config::defaults(BehaviorVersion::latest())
    .region("us-east-1")
    .load()
    .await;

let service = aws_sdk_s3::config::Builder::from(&shared)
    .force_path_style(true)
    .build();
let client = Client::from_conf(service);

export T9_CLOUD_ADAPTER_ENDPOINT="https://adapter.example.test"

use aws_config::BehaviorVersion;
use aws_sdk_s3::Client;

async fn adapter_client() -> Client {
    let shared = aws_config::defaults(BehaviorVersion::latest())
        .region("us-east-1")
        .load()
        .await;

    let service = aws_sdk_s3::config::Builder::from(&shared)
        .endpoint_url(std::env::var("T9_CLOUD_ADAPTER_ENDPOINT").expect("T9_CLOUD_ADAPTER_ENDPOINT"))
        .force_path_style(true)
        .build();

    Client::from_conf(service)
}

use aws_sdk_s3::primitives::ByteStream;

let client = adapter_client().await;
let bucket = std::env::var("TEST_BUCKET")?;
let key = format!("rust/{}-hello.txt", std::time::SystemTime::now()
    .duration_since(std::time::UNIX_EPOCH)?.as_millis());
let expected = b"hello through Cloud Adapter\n".to_vec();

client.put_object()
    .bucket(&bucket)
    .key(&key)
    .content_type("text/plain")
    .body(ByteStream::from(expected.clone()))
    .send().await?;

client.head_object().bucket(&bucket).key(&key).send().await?;

let response = client.get_object().bucket(&bucket).key(&key).send().await?;
let actual = response.body.collect().await?.into_bytes();
assert_eq!(actual.as_ref(), expected.as_slice());

client.delete_object().bucket(&bucket).key(&key).send().await?;