使用pymongo處理數據mysql
from pymongo import MongoClientsql
class MongoDatabaseAction(object):
def __init__(self,host=HOST,db_name=M_DATABASE):
self.__Log = Logger().get_logger('ReportServer.MongoDatabaseConnection')
self.connect_mongo_server(host)
self.open_database(db_name)
def connect_mongo_server(self,host):
self.conn = MongoClient(HOST,27017)mongodb
def open_database(self,db_name):
self.database = self.conn[db_name]
def open_collection(self,collection_name=M_COLLECTION):
self.db_collection = self.database[collection_name]spa
\\
rest
建立db和collection的時候沒有出現問題,但在insert時出現問題,提示mongodb鏈接失敗:server
pymongo.errors.ServerSelectionTimeoutError: 10.140.161.59:27017: [Errno 111] Connection refusedip
緣由是:get
vi /etc/mongodb.confit
bind_ip = 127.0.0.1註銷掉pip
service mongodb restart便可,和mysql相似
使用
解決辦法,升級pymongo版本:
pip install pymongo==2.7.2 --proxy http://10.144.1.10:8080