Python访问MongoDB,并且转换成Dataframe的方法
如下所示：
#!/usr/bin/envpython
#-*-coding:utf-8-*-
#@Time:2018/7/1311:10
#@Author:baoshan
#@Site:
#@File:pandans_pymongo.py
#@Software:PyCharmCommunityEdition
importpymongo
importpandasaspd
def_connect_mongo(host,port,username,password,db):
"""Autilformakingaconnectiontomongo."""
ifusernameandpassword:
mongo_uri="mongodb://%s:%s@%s:%s/%s"%(username,password,host,port,db)
conn=pymongo.MongoClient(mongo_uri)
else:
conn=pymongo.MongoClient(host,port)
returnconn[db]
defread_mongo(db,collection,query={},host='test43',port=27017,username=None,password=None,no_id=True):
"""ReadfromMongoandStoreintoDataFrame."""
#ConnecttoMongoDB
db=_connect_mongo(host=host,port=port,username=username,password=password,db=db)
#MakeaquerytothespecificDBandCollection
cursor=db[collection].find(query).limit(10)
#ExpandthecursorandconstructtheDataFrame
df=pd.DataFrame(list(cursor))
df.to_csv("abc.csv",encoding="utf_8_sig")#处理中文乱码问题
ifno_id:
deldf['_id']
returndf
read_mongo(db='service',collection='trace_log_regular',query={},host='xxx',port=27017,username="xxx",password="xxx")
小结：
1.解决了pymongo访问MongoDB的问题
2.解决了查询的数据转成dataframe的问题
3.解决了dataframe写入到csv的问题
4.解决了中文乱码问题。
以上这篇Python访问MongoDB,并且转换成Dataframe的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。