我試圖通過磚Notbook運行更大的sql腳本和導出數據到一個文件。大部分筆記本工作時,sql腳本是一個SELECT語句。然而,如果等更複雜的sql文件包含創建一個臨時的使用/揮發性表,插入數據,更新它,然後輸出結果失敗,如下所示。
我能在雪花上運行SQL腳本沒有任何問題,但是,當建立連接但磚隻是不想跑,我不懂這個問題。
% python #完整的SQL腳本運行在雪花,但似乎問題張開(' / dbfs / FileStore / myid / prjX_sf。sqlFile sql”、“r”): #錯誤,創建臨時表,插入數據,更新臨時表,select語句張開(' / dbfs / FileStore / # myid / prjX_simple。sql”、“r”)作為sqlFile: #作品,select語句隻sql_script = sqlFile.read() #讀取數據從表雪花df =火花。讀\ .format(“雪花”)\ .options康涅狄格州(* *)\ .option(“查詢”,sql_script) \ .load()顯示(df)
net.snowflake.client.jdbc。SnowflakeSQLException: SQL編譯錯誤:
Py4JJavaError:調用o3645.load時發生一個錯誤。
:net.snowflake.client.jdbc。SnowflakeSQLException: SQL編譯錯誤:
語法錯誤在位置1號線15意想不到的“下降”。
語法錯誤285行位置63意想不到的)。
嗨@Marco佩雷斯,
我想分享以下文檔https://docs.m.eheci.com/external-data/snowflake.html query-a-snowflake-table-in-databricks在這裏你可以找到示例代碼使用磚如何讀取數據