python连接mongodb集群方法详解

简单的测试用例

1. #!/usr/bin/python
2. # -*- coding: UTF-8 -*-
3. import time
4. from pymongo import MongoClient
5. # 连接单机
6. # single mongo
7. # c = MongoClient(host="192.168.89.151", port=27017)
8. # 连接集群
9. c = MongoClient('mongodb://192.168.89.151,192.168.89.152,192.168.89.153')

大型项目的使用方式

三个目录：

目录a为config目录，存放项目的配置文件，主要由conf.ini和__init__.py组成 

目录b存放需要运行的项目模块，我们这里只用main.py就可以了

目录c为utils目录，存放一些常用的函数，我们的mongo连接类就放在该目录下

conf.ini文件如下：

[MONGO]

dev.host = mongodb://10.0.53.xx:10010,10.0.53.xx:10010,10.0.53.xx:10010

__init__.py文件如下：

import configparser

1. import configparser
2.  
3. #定义环境变量
4. env = 'dev'
5. profile = env + '.'
6.  
7. #从conf.ini中读取变量
8. config = configparser.ConfigParser()
9. config.read(os.path.join(os.path.dirname(os.path.realpath(__file__)), 'conf.ini'))
10.  
11. for section in config.sections():
12. for key, val in config.items(section):
13. if key.startswith(profile):
14. CONFIG_DICT['{0}_{1}'.format(section, key.replace(profile, '').upper())] = val
15.  
16. #通过conf.ini定义变量
17. MONGO_HOST = CONFIG_DICT['MONGO_HOST']

更多关于python连接mongodb集群方法详解的文章请查看下面的相关文章