Я создал записную книжку с простой командой для чтения таблицы из SQL Pool и ее отображения:
%%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 указан как пользователь в базе данных I Я читаю, а также имеет роль db_owner. Я также пробовал конвейер «копировать данные» в / из пула SQL, и это действительно сработало при запуске.
Возможно, мы пропустили шаг настройки при настройке среды? Есть идеи по устранению этой конкретной ошибки?