如何閱讀python中的sql筆記本筆記本工作區嗎

[NavyaD]

我有一個筆記本ecom_sellout命名。sql路徑下筆記本/ python / dataloader /查詢。

我有另一個筆記本(名為dataloader路徑下筆記本/ python / dataloader)我打電話這個sql的筆記本。

回購我的代碼運行非常好,但是我想運行它在工作區&計劃通過工作區筆記本工作

我共享的代碼

def query_database_with_params(自我,路徑:str, table_name: str, * * kwargs) - > DataFrame:

”“”

從文件加載一個SQL語句和查詢數據集的火花,指定表名和

國家篩選表

參數:

路徑(str):字符串指定SQL語句的位置

table_name (str):字符串指定的表的名稱

* * kwargs:參數存儲字符串填充的參數經常sql文件

返回:

Pyspark Dataframe:使用參數化SQL Dataframe加載到火花

”“”

張開f(路徑,“r”):

查詢= f.read ()

查詢查詢=。形式at(table_name=table_name, **kwargs)

返回self.spark.sql(查詢)

函數是未能打開&說,文件或目錄的路徑不存在

然而在同一位置的文件。

有人可以請解釋如何閱讀磚工作區上的sql文件

[Aviral-Bhardwaj]

使用魔法的命令,另一方麵你可以使用python和SQL格式。它將工作

[NavyaD]

函數是在一個類&你能請給一個簡短的解釋我如何使用魔法的命令,你是什麼意思,python和sql編製器。