HungYangChang commented on issue #1588:
URL:
https://github.com/apache/iceberg-python/issues/1588#issuecomment-2637890569
I found out actually it's not the file_io issue
I am able to solved it
My new code with testing against lakekeepr
```
set up env variable (this solves this error: Must provide either a
connection_string or account_name with credentials!! ):
AZURE_STORAGE_CLIENT_ID = os.environ.get("AZURE_STORAGE_CLIENT_ID")
AZURE_STORAGE_CLIENT_SECRET = os.environ.get("AZURE_STORAGE_CLIENT_SECRET")
AZURE_STORAGE_TENANT_ID = os.environ.get("AZURE_STORAGE_TENANT_ID")
AZURE_STORAGE_ACCOUNT_NAME = os.environ.get("AZURE_STORAGE_ACCOUNT_NAME")
credential = ClientSecretCredential(
tenant_id=AZURE_STORAGE_TENANT_ID,
client_id=AZURE_STORAGE_CLIENT_ID,
client_secret=AZURE_STORAGE_CLIENT_SECRET
)
file_io = FsspecFileIO(properties={"account_name":
AZURE_STORAGE_ACCOUNT_NAME, "credential": credential})
catalog = RestCatalog(
name="test_catalog",
uri=CATALOG_URL,
warehouse=WAREHOUSE_PATH,
token="dummy",
properties={
# either adlfs or adls can be used
"adlfs.account-name": AZURE_STORAGE_ACCOUNT_NAME,
"adlfs.container": CONTAINER_NAME,
"adlfs.client-id": AZURE_STORAGE_CLIENT_ID,
"adlfs.tenant-id": AZURE_STORAGE_TENANT_ID,
"adlfs.client-secret": AZURE_STORAGE_CLIENT_SECRET, # ✅ Use Service
Principal
"client_secret": AZURE_STORAGE_CLIENT_SECRET,
"client_id": AZURE_STORAGE_CLIENT_ID,
"tenant_id": AZURE_STORAGE_TENANT_ID,
"io-impl": "pyiceberg.io.fsspec.FsspecFileIO",
}
)
catalog.file_io = file_io
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
