chore(deps): Update Azure crates (May 2026 release) (#25492)

* update Azure crates to 1.0

* sdk changes

* futures related changes

* Change TryRecvError::Closed to ::Empty

---------

Co-authored-by: Thomas <thomas.schneider@datadoghq.com>

Author: jlaundry

Cargo.lock

@@ -226,7 +226,7 @@ strum = { version = "0.28", features = ["derive"] }
 [dependencies]
 cfg-if.workspace = true
 reqwest.workspace = true
-reqwest_13 = { package = "reqwest", version = "0.13", default-features = false, features = ["json", "rustls-no-provider"] }
+reqwest_13 = { package = "reqwest", version = "0.13", default-features = false, features = ["json", "native-tls", "rustls-no-provider"] }
 clap.workspace = true
 clap_complete.workspace = true
 indoc.workspace = true
@@ -306,11 +306,11 @@ aws-smithy-runtime-api = { version = "1.7.3", default-features = false, optional
 aws-smithy-types = { version = "1.2.11", default-features = false, features = ["rt-tokio"], optional = true }
 
 # Azure
-azure_core = { version = "0.33", features = ["reqwest", "hmac_openssl"], optional = true }
-azure_identity = { version = "0.33", features = ["client_certificate"], optional = true }
+azure_core = { version = "1.0", default-features = false, features = ["reqwest", "hmac_openssl"], optional = true }
+azure_identity = { version = "1.0", default-features = false, features = ["client_certificate"], optional = true }
 
 # Azure Storage
-azure_storage_blob = { version = "0.10.1", optional = true }
+azure_storage_blob = { version = "1.0", default-features = false, optional = true }
 
 # OpenDAL
 opendal = { version = "0.54", default-features = false, features = ["services-webhdfs"], optional = true }

Cargo.toml

@@ -379,7 +379,7 @@ impl AzureBlobSinkConfig {
             .await
             .expect("Failed to download blob");
         let body_bytes = downloaded
-            .into_body()
+            .body
             .collect()
             .await
             .expect("Failed to read blob body");

src/sinks/azure_blob/integration_tests.rs

@@ -637,8 +637,8 @@ pub async fn build_client(
             .build()
             .map_err(|e| format!("Failed to build reqwest client: {e}"))?,
     )));
-    let client = BlobContainerClient::from_url(url, credential, Some(options))
-        .map_err(|e| format!("{e}"))?;
+    let client =
+        BlobContainerClient::new(url, credential, Some(options)).map_err(|e| format!("{e}"))?;
     Ok(Arc::new(client))
 }
 

src/sinks/azure_common/config.rs

@@ -48,7 +48,7 @@ impl Service<AzureBlobRequest> for AzureBlobService {
                 blob_content_encoding: request.content_encoding.map(|e| e.to_string()),
                 ..Default::default()
             }
-            .with_if_not_exists();
+            .if_not_exists();
 
             let result = blob_client
                 .upload(