通过Python实现对MongoDB集群的连接
发布时间
阅读量:
阅读量
1、安装pyMongo
(前提条件:系统中需已配置Python及pip环境)
在命令提示符界面中执行pip instal pymongo指令,随后等待软件包完成安装过程;
2、连接MongoDB
以下为相关代码实现:
from pymongo import MongoClient, ReadPreference
def db_conn():
client = MongoClient(['192.168.2.188:20000', '192.168.2.190:20000', '192.168.2.191:20000'])
db_auth = client.admin
db_auth.authenticate('lty', 'lty@100729')
db = client.get_database('kafka_test', read_preference=ReadPreference.SECONDARY_PREFERRED)
collection = db.ITS_Topic_CommandACK
for x in collection.find():
print(x);
if __name__ == '__main__':
全部评论 (0)
还没有任何评论哟~
