1.读取mongodb数据库集合到DataFrame
import pymongoimport pandas as pdclient = pymongo.MongoClient("数据库连接字符串") # 第二种方式 host='localhost', port=27017db = client['要读取的数据库名']coll_name = db['要读取的集合名']# 读取mongodb的集合到pandasdf = pd.DataFrame(list(coll_name.find())) # df 就是读取的mongodb的集合，DataFrame类型del df['_id'] # 删除读取的id,
2.将DataFrame类型数据保存到mongodb数据库中
import pymongoimport pandas as pd#第一种是字符串连接， 第二种方式 host='localhost', port=27017client = pymongo.MongoClient("数据库连接字符串") db = client['要保存的数据库名']coll_name = db['要保存的集合名']# 将DataFrame存入到mongodb中df = df.to_dict(orient='records') # 固定写法coll_name.insert_many(df)
