Advertisement

通过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)

还没有任何评论哟~