azure_storage_blobs

Azure Blob Storage crate from the Azure SDK for Rust

19 breaking releases

0.20.0 Apr 24, 2024
0.19.0 Jan 5, 2024
0.18.0 Dec 11, 2023
0.17.0 Nov 3, 2023
0.1.0 Jan 25, 2022

#6 in Caching

Download history 34516/week @ 2024-06-19 45843/week @ 2024-06-26 36261/week @ 2024-07-03 44300/week @ 2024-07-10 38477/week @ 2024-07-17 43516/week @ 2024-07-24 41096/week @ 2024-07-31 37464/week @ 2024-08-07 48513/week @ 2024-08-14 49519/week @ 2024-08-21 49706/week @ 2024-08-28 48205/week @ 2024-09-04 39845/week @ 2024-09-11 40092/week @ 2024-09-18 44874/week @ 2024-09-25 31720/week @ 2024-10-02

163,968 downloads per month
Used in 15 crates (13 directly)

MIT license

6MB
104K SLoC

azure_storage_blobs

This crate is from the Azure SDK for Rust. It supports Azure Blob Storage.

Example


use azure_core::error::{ErrorKind, ResultExt};
use azure_storage::prelude::*;
use azure_storage_blobs::prelude::*;
use futures::stream::StreamExt;

#[tokio::main]
async fn main() -> azure_core::Result<()> {
    let file_name = "azure_sdk_for_rust_stream_test.txt";

    // First we retrieve the account name and access key from environment variables.
    let account = std::env::var("STORAGE_ACCOUNT").expect("missing STORAGE_ACCOUNT");
    let access_key = std::env::var("STORAGE_ACCESS_KEY").expect("missing STORAGE_ACCOUNT_KEY");
    let container = std::env::var("STORAGE_CONTAINER").expect("missing STORAGE_CONTAINER");
    let blob_name = std::env::var("STORAGE_BLOB_NAME").expect("missing STORAGE_BLOB_NAME");

    let storage_credentials = StorageCredentials::access_key(account.clone(), access_key);
    let blob_client = ClientBuilder::new(account, storage_credentials).blob_client(&container, blob_name);

    blob_client.put_block_blob("hello world").content_type("text/plain").await?;

    let mut result: Vec<u8> = vec![];

    // The stream is composed of individual calls to the get blob endpoint
    let mut stream = blob_client.get().into_stream();
    while let Some(value) = stream.next().await {
        let mut body = value?.data;
        // For each response, we stream the body instead of collecting it all
        // into one large allocation.
        while let Some(value) = body.next().await {
            let value = value?;
            result.extend(&value);
        }
    }

    println!("result: {:?}", result);

    Ok(())
}

License: MIT

Dependencies

~8–22MB
~327K SLoC