python3远程操作mongodb

不念不忘少年蓝@ 2022-09-06 00:14 244阅读 0赞

1、安装mongodb模块，解决以下报错  
ModuleNotFoundError: No module named ‘pymongo‘

yum -y install python3-pip
    pip3 install pymongo

2、编写一个操作mongodb的python3脚本

#!/usr/bin/python3
    #encoding=utf-8
    
    import pymongo
    
    class MongoDBConect(object):
        def __init__(self,host,port,username,password,db_name,collection,record):
            self.host = host
            self.port = port
            self.username = username
            self.password = password
            self.db_name = db_name
            self.collection = collection
            self.record = record
    
        def connect(self):
            #client = pymongo.MongoClient('mongodb://localhost:27017')
            #或
            #client = pymongo.MongoClient('localhost'，'27017')
            # 如果设置了权限,注意xxx用户权限要可以cover到后面使用到的数据库
            #client = pymongo.MongoClient('192.168.1.48', 27017, username='root', password='123456')
            client = pymongo.MongoClient(self.host, self.port, username=self.username, password=self.password)
    
            db = client[self.db_name]
    
    
            collection_test01 = db[self.collection]
    
            try:
                for record in self.record:
                    collection_test01.save(record)
            except pymongo.errors.DuplicateKeyError:
                print('record exists')
            except Exception as e:
                print("e")
    
    if __name__ == '__main__':
        record_l = [
        { '_id':0,'name': 'zzzzz','age': -27,'high': 176},
        { '_id':1,'name': 'zhangweijian','age': 27,'high': 171},
        { '_id':2,'name': 'zhang','age': 26,'high': 173},
        { '_id':3,'name': 'wei','age': 29,'high': 180},
        { '_id':4,'name': 'weijian','age': 30,'high': 158},
        { '_id':5,'name': 'zhangjian','age': 22,'high': 179},
        { '_id':6,'name': 'zwj','age': 19,'high': 166},
        { '_id':100,'name': 'zwj','age': 19,'list':[2,3,5]},
        { '_id':101,'name': 'zwj','age': 19,'list':[1,2,3,4,5,6,7]},
        ]
        MongoCon=MongoDBConect('192.168.1.48',27017,'root','123456','aitdtest','test03',record_l)
        MongoCon2=MongoDBConect('192.168.1.48',27017,'root','123456','aitdtest','test03',[{ '_id':7,'name': 'liuys','age': 19,'high': 186},{ '_id':8,'name': 'liuys','age': 19,'high': 186,'weight': 140}])
        MongoCon.connect()
        MongoCon2.connect()
    #dblist = myclient.list_database_names()

3、查询执行后的结果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70]: /images/20220829/f638c6691825428fbfaafd3eec1553bf.png