Pyspark——如何拯救一個csv文件的模式在三角洲表的列中

[tarente]

如何拯救一個csv文件的模式在三角洲表的列?

在之前的項目中實現磚使用Scala的筆記本,我們存儲模式的csv文件作為一個json字符串在SQL Server表。

當我們需要讀或寫csv和源dataframe das 0行,源csv或不存在,我們使用模式存儲在SQL Server創建一個空dataframe或空的csv文件。

現在,我想實現在磚類似,但使用Python筆記本和csv文件的模式存儲在三角洲表。

有什麼建議嗎?

提前謝謝,

蒂亞戈。

[RKNutalapati · Accepted solution]

嗨@Tiago年金,希望下麵的代碼會有所幫助。

[tarente]

你好,

謝謝你的代碼,我將測試它。

問候,

蒂亞戈。

[匿名]

@Tiago年金——測試怎麼樣?

[tarente]

嗨,風笛手,

不幸的是,我沒能測試它之前我改變到一個新的雇主,所以我不能再測試它。然而,我認為這是可行的。

問候,

蒂亞戈R。

[匿名]

@tarente——謝謝你讓我們知道。