取消
顯示的結果
而不是尋找
你的意思是:

通過筆記本Python運行SQL數據文件

Marco9898
新的貢獻者二世

我試圖通過磚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意想不到的)。

2回答2

jose_gonzalez
主持人
主持人

嗨@Marco佩雷斯,

我想分享以下文檔https://docs.www.eheci.com/external-data/snowflake.html query-a-snowflake-table-in-databricks在這裏你可以找到示例代碼使用磚如何讀取數據

Vidula_Khanna
主持人
主持人

嗨@Marco佩雷斯

@Jose岡薩雷斯反應回答你的問題嗎?如果是的,你會很高興其標記為最好所以,其他成員可以找到解決方案更快嗎?

我們很想聽到你的聲音。

謝謝!

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map