azurestorageblobs

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

Example

```rust

use azurecore::error::{ErrorKind, ResultExt}; use azurestorage::prelude::; use azure_storage_blobs::prelude::; use futures::stream::StreamExt;

[tokio::main]

async fn main() -> azurecore::Result<()> { let filename = "azuresdkforruststream_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::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