commit 7242a95e49fe5bd07089b5ca16f9bf576eeba825
author ByteBaker <42913098+ByteBaker@users.noreply.github.com> Wed Jul 09 03:16:53 2025 +0530
committer Marco Neumann <marco@crepererum.net> Thu Jul 10 16:15:48 2025 +0200
tree 41aa1966ad72bbf1735d8583ab8c62baf4f3c7c9
parent 1de3c7854a2358ef423bc6a02ed86644a77baab0

feat (azure): support for account in 'az://' URLs (#403)

src/azure/builder.rs

diff --git a/src/azure/builder.rs b/src/azure/builder.rs
index e97e83e..182bdf0 100644
--- a/src/azure/builder.rs
+++ b/src/azure/builder.rs
@@ -658,8 +658,8 @@
         };
 
         match parsed.scheme() {
-            "az" | "adl" | "azure" => self.container_name = Some(validate(host)?),
-            "abfs" | "abfss" => {
+            "adl" | "azure" => self.container_name = Some(validate(host)?),
+            "az" | "abfs" | "abfss" => {
                 // abfs(s) might refer to the fsspec convention abfs://<container>/<path>
                 // or the convention for the hadoop driver abfs[s]://<file_system>@<account_name>.dfs.core.windows.net/<path>
                 if parsed.username().is_empty() {
@@ -1105,6 +1105,14 @@
 
         let mut builder = MicrosoftAzureBuilder::new();
         builder
+            .parse_url("az://container@account.dfs.core.windows.net/path-part/file")
+            .unwrap();
+        assert_eq!(builder.account_name, Some("account".to_string()));
+        assert_eq!(builder.container_name, Some("container".to_string()));
+        assert!(!builder.use_fabric_endpoint.get().unwrap());
+
+        let mut builder = MicrosoftAzureBuilder::new();
+        builder
             .parse_url("abfss://file_system@account.dfs.fabric.microsoft.com/")
             .unwrap();
         assert_eq!(builder.account_name, Some("account".to_string()));