feat(object store): support azblob workload identity

Cargo.toml

@@ -304,6 +304,7 @@ tokio-postgres = { git = "https://github.com/madsim-rs/rust-postgres.git", rev =
 futures-timer = { git = "https://github.com/madsim-rs/futures-timer.git", rev = "05b33b4" }
 # patch: unlimit 4MB message size for grpc client
 etcd-client = { git = "https://github.com/risingwavelabs/etcd-client.git", rev = "4e84d40" }
+reqsign = { git = "https://github.com/wcy-fdu/reqsign.git", rev = "7ca1d72" }
 
 [workspace.metadata.dylint]
 libraries = [{ path = "./lints" }]

src/object_store/Cargo.toml

@@ -37,6 +37,10 @@ thiserror-ext = { workspace = true }
 tokio = { version = "0.2", package = "madsim-tokio", features = ["fs"] }
 tokio-retry = "0.3"
 tracing = "0.1"
+
+[patch.crates-io]
+reqsign = { git = "https://github.com/wcy-fdu/reqsign.git", rev = "f6ff677" }
+
 # This crate is excluded from hakari (see hakari.toml) after hdfs is introduced...## [target.'cfg(not(madsim))'.dependencies]
 # workspace-hack = { path = "../workspace-hack" }
 #

src/object_store/src/object/opendal_engine/azblob.rs

@@ -28,14 +28,14 @@ impl OpendalObjectStore {
 
         let endpoint = std::env::var("AZBLOB_ENDPOINT")
             .unwrap_or_else(|_| panic!("AZBLOB_ENDPOINT not found from environment variables"));
-        let account_name = std::env::var("AZBLOB_ACCOUNT_NAME")
-            .unwrap_or_else(|_| panic!("AZBLOB_ACCOUNT_NAME not found from environment variables"));
-        let account_key = std::env::var("AZBLOB_ACCOUNT_KEY")
-            .unwrap_or_else(|_| panic!("AZBLOB_ACCOUNT_KEY not found from environment variables"));
+        // let account_name = std::env::var("AZBLOB_ACCOUNT_NAME")
+        //     .unwrap_or_else(|_| panic!("AZBLOB_ACCOUNT_NAME not found from environment variables"));
+        // let account_key = std::env::var("AZBLOB_ACCOUNT_KEY")
+        //     .unwrap_or_else(|_| panic!("AZBLOB_ACCOUNT_KEY not found from environment variables"));
 
         builder.endpoint(&endpoint);
-        builder.account_name(&account_name);
-        builder.account_key(&account_key);
+        // builder.account_name(&account_name);
+        // builder.account_key(&account_key);
         let op: Operator = Operator::new(builder)?
             .layer(LoggingLayer::default())
             .layer(RetryLayer::default())