如何把緩存的SQL表到Python字典嗎?

[drewtoby]

你好,

我一直工作在這個問題上作為一個概念證明——這將是非常有用的在一些場景中通過循環遍曆表。我有一個簡單的三維列添加到緩存的表。

緩存表hofhc.hedis_dim hedis_cache select *懶惰

然後我嚐試以下兩種方法。第一個是空的,而第二個是dataframe返回數據,而不是python字典。

任何建議嗎?提前感謝你所有的幫助!

[daniel_sahal · Accepted solution]

@Andrew貝格

首先,緩存表創建一個視圖,不表,所以你不能用pd。read_table (https://docs.m.eheci.com/sql/language-manual/sql-ref-syntax-aux-cache-cache-table.html)。

第二種方法——.select()仍然給dataframe作為輸出。你需要找到一種方法將對dict DF。

[drewtoby]

找到了工作,謝謝你的提示!我需要把熊貓dataframe dataframe結束

https://www.geeksforgeeks.org/convert-pyspark-dataframe-to-dictionary-in-python/