We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b806cfa commit 47bf8aeCopy full SHA for 47bf8ae
pyiceberg/io/fsspec.py
@@ -179,6 +179,16 @@ def _gs(properties: Properties) -> AbstractFileSystem:
179
def _adls(properties: Properties) -> AbstractFileSystem:
180
from adlfs import AzureBlobFileSystem
181
182
+ for key, sas_token in {
183
+ key.replace(f"{ADLS_SAS_TOKEN}.", ""): value
184
+ for key, value in properties.items()
185
+ if key.startswith(ADLS_SAS_TOKEN) and key.endswith(".windows.net")
186
+ }.items():
187
+ if ADLS_ACCOUNT_NAME not in properties:
188
+ properties[ADLS_ACCOUNT_NAME] = key.split(".")[0]
189
+ if ADLS_SAS_TOKEN not in properties:
190
+ properties[ADLS_SAS_TOKEN] = sas_token
191
+
192
return AzureBlobFileSystem(
193
connection_string=properties.get(ADLS_CONNECTION_STRING),
194
account_name=properties.get(ADLS_ACCOUNT_NAME),
0 commit comments