範例原始碼在這邊:
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import pymongo | |
import pandas as pd | |
# 連線 mongodb | |
db = pymongo.MongoClient("XXXXXXXX") | |
# 將資料取回 | |
find = {'channel_id':channel_id} | |
data = db.ufs.tag_log.find(find).limit(100) | |
datalist = [] | |
for row in data: | |
設定要寫入 DataFrame 的單一列資料 | |
r = { | |
"user_id":row['user_id'], | |
"tag":row['tag'], | |
"datetime":row['datetime'] | |
} | |
datalist.append(r) | |
# 轉換成 DataFrame | |
l = pd.DataFrame(datalist) |
大略解釋一下:
原理是這樣的,DataFrame 要先一行一行的建立每一筆 dist 資料,也就是 (#5) 的 r 這個變數。
再將 dist 丟入 datalist 這個 list 中。(#22)
最後就可以轉成 DataFrame 的格式了(#25)
延伸閱讀:
留言
張貼留言