1

我用一个简单的命令创建了一个笔记本,从 SQL 池中读取一个表并显示它:

%%spark
val df = spark.read.sqlanalytics("pool1.dbo.Trip")
display(df)

当我手动运行此笔记本时,它按预期工作。当我将笔记本拖入 Azure Synapse 单步管道并手动触发时,管道失败并出现错误:

{"code":"InternalServerError","message":"InternalServerError executing request","target":"pipeline/Pipeline 1/runid/6938bd4c-35f4-414a-80d9-582dde84651c","details":null,"error":null}

azure synapse 服务主体在我正在读取的数据库中列为用户,并且还具有 db_owner 角色。我还尝试了与 SQL 池之间的“复制数据”管道,并且在触发时实际上成功了。

在设置环境时,我们是否可能错过了配置步骤?解决此特定错误的任何想法?

4

0 回答 0