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