将极坐标数据帧写入 Microsoft Lakehouse 中的增量表

Question

我目前正在开展一个项目，在 Fabric Notebook 中使用 Polars，我想将此数据保存到 Microsoft Fabric Lakehouse 内的 Delta 表中。我在想这样的事情：

df.write_delta(f"abfss://[e-mail]/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/Tables/xxx", 
               mode="append",
               storage_options={
                   "use_fabric_endpoint": "https://onelake.dfs.fabric.microsoft.com"
               })

但是，我遇到以下错误：

OSError：通用MicrosoftAzure错误：执行令牌请求时出错：13.93100353秒内重试10次后出错，max_retries：10，retry_timeout：180s，源：发送url请求时出错（http://xxx.xxx.xxx.xxx/元数据/identity/oauth2/token?api-version=2019-08-01&resource=https%3A%2F%2Fstorage.azure.com)

如何正确配置？

提前感谢您的帮助！

致以诚挚的问候，

穆拉德

Answer 1

如果您不使用 Spark 或本地挂载点，则您负责向 OneLake 进行身份验证。

所以您似乎没有向 OneLake 进行身份验证。 您需要配置该库以使用 OAuth 和服务主体来连接 OneLake。

最简单的事情可能是本地文件系统挂载，它是预先验证的。

/lakehouse/default/Tables/...