文章目录
- pymongo连接
- 新建数据库和集合
- pandas导入数据
- 插入数据
- 数据查看
pymongo连接
import pymongo
client = pymongo.MongoClient("mongodb://localhost:27017/")
dblist = client.list_database_names()
for db in dblist:
print(db) #查看已有数据库
admin
bilibili
config
local
student
新建数据库和集合
import pandas as pd
db=client['government']
col=db['policy']
pandas导入数据
使用df.to_dict
函数,返回结果为列表,列表中的每个元素为json型,是原来excel中的一条记录。
df = pd.read_excel('汽车行业政策文本研究.xlsx')
print(df.columns)
# orient='records', 表示将DataFrame的数据转换成我想要的json格式
data_json = df.to_dict(orient='records')
print(type(data_json))
插入数据
col.insert_many(data_json) #一次性插入多条
#for dt in data_json: #一次一条
#col.insert_one(dt)
数据查看