Pymongo 连接mongodb集群

老师，你好请问一下，搭建了mongodb集群分片(Sharding)模式，如何通过python去操作呢，网上查询到的资料都好少，我直接使用 python操作 mongos 报错呢。

AmoXiang 2022-11-29

源自：MongoDB与Python的交互 2-5 pymongo模块向MongDB中保存文件

收起

1回答

好帮手慕凡 2022-11-29 10:09:26

同学，你好！

同学可以参考以下代码

import pymongo

conn = pymongo.Connection('127.0.0.1', 27017) 
db = conn['test'] #连接test数据库 
db_admin = conn['admin'] #command的执行必须通过名为admin的db才能进行 
col_data = db["data"] 
db_admin.command('enablesharding', 'test') #确认目标db的sharding功能开启(这行代码一个数据库只执行一次有效，如果已经设置，则会抛出异常)
db_admin.command('shardcollection', 'test.data', key = {'_id':1}) #指定目标collection和对应的shard key（这行一个表执行一次，如果出现多表，表名不同的情况下，应该每张表都执行一次）
conn.close()

同学在连接过程中遇到错误，可以根据错误去解决问题，祝学习愉快~

收起回答

提问者 AmoXiang #1

import pymongo
client = pymongo.MongoClient(host="我的host", port=11111,username="******",password="*****")
db_admin = client['testamo']  # command的执行必须通过名为admin的db才能进行
conn = db_admin['amo']  # 连接test数据库
student1 = {"id": '20170101', "name": "AmoXiang", "age": 20, "gender": "male"}
result = conn.insert_one(student1)
print(result)
print(result.inserted_id)
client.close()

老师我像上面这样测试报错了我是通过连接的mongos的服务，mongos好像是自动分发路由，但是我一执行插入和查询操作就报错。我在集群中testamo这个库和amo这个集合都是设置了分片的

2022-11-29 11:32:47

提问者 AmoXiang #2

老师上图中有个截图是执行的testdb是截图错误

2022-11-29 11:35:04
好帮手慕凡回复提问者 AmoXiang #3

同学，你好！
老师这边对mongodb集合相关问题不太了解，同学可以学习以下https://www.imooc.com/learn/501 MongoDB集群之分片技术应用课程，祝学习愉快~

2022-11-29 14:58:56