分片是mongoDB擴展的一種方式。分片分割一個collection并將不同的部分存儲在不同的機器上。當一個數(shù)據(jù)庫的collections相對于當前空間過大時,你需要增加一個新的機器。分片會自動的將collection數(shù)據(jù)分發(fā)到新的服務器上。
1. 連接到mongos可查看系統(tǒng)相關信息
configsvr> show dbsconfigsvr> use configconfigsvr> show collectionsonfigsvr> db.mongos.find(){ "_id" :"racdb:28885", "ping" :ISODate("2016-03-21T09:23:05.106Z"), "up" :NumberLong(1436), "waiting" : true, "mongoVersion" :"3.2.3" }{ "_id" :"host8.localdomain:28885", "ping" :ISODate("2016-03-21T09:23:07.960Z"), "up" :NumberLong(1427), "waiting" : true, "mongoVersion" :"3.2.3" }{ "_id" :"host9.localdomain:28885", "ping" :ISODate("2016-03-21T09:23:03.521Z"), "up" :NumberLong(1407), "waiting" : true, "mongoVersion" :"3.2.3" }configsvr> db.shards.find(){ "_id" : "shard1","host" : "shard1/host8:28017,racdb:28017" }{ "_id" : "shard2","host" : "shard2/host8:28018,racdb:28018" }configsvr> db.databases.find(){ "_id" :"im_offline_msg", "primary" : "shard1","partitioned" : true }{ "_id" : "testdb","primary" : "shard2", "partitioned" : true }{ "_id" : "test","primary" : "shard1", "partitioned" : true }{ "_id" : "blogdb","primary" : "shard2", "partitioned" : false }
2. 對數(shù)據(jù)庫啟用分片
2.1 當前可連接到 mongos 查看數(shù)據(jù)庫或者集合的分片情況(沒有分片):
mongos> db.stats()mongos> db.tab.stats()
2.2 對數(shù)據(jù)庫激活分片功能:
# mongo racdb:28885mongos>sh.enableSharding("test")#或者# mongo racdb:28885mongos> use adminmongos> db.runCommand( { enableSharding:"blogdb"} )
2.3 此時查看數(shù)據(jù)庫分區(qū)情況,partitioned變?yōu)?“true”。
configsvr> use configswitched to db configconfigsvr> db.databases.find(){ "_id" :"im_offline_msg", "primary" : "shard1","partitioned" : true }{ "_id" : "testdb","primary" : "shard2", "partitioned" : true }{ "_id" : "test","primary" : "shard1", "partitioned" : true }{ "_id" : "blogdb","primary" : "shard2", "partitioned" : true }
啟用數(shù)據(jù)庫分片并沒有將數(shù)據(jù)進行分開,還需要對 collection 進行分片。
3. 對集合啟用分片
啟用前,有幾個問題需要考慮的:
選擇哪個鍵列作為shard key 。(更多參考:Considerations for Selecting Shard Keys)
如果集合中已經存在數(shù)據(jù),在選定作為shard key 的鍵列必須創(chuàng)建索引;如果集合為空,mongodb 將在激活集合分片(sh.shardCollection)時創(chuàng)建索引。
集合分片函數(shù)sh.shardCollection ,
sh.shardCollection(".",shard-key-pattern)
mongos>sh.shardCollection("test.tab", { "_id": "hashed"})
測試插入數(shù)據(jù):
--使用python命令#創(chuàng)建python文件$ vi batch_insert.py#-*- coding: UTF-8 -*-import pymongoclient = pymongo.MongoClient("racdb", 28885)db = client.testdb#查看testdb數(shù)據(jù)庫中集合信息print (db.collection_names())#連接到my_collection集合print (db.my_collection)#清空my_collection集合文檔信息db.my_collection.remove()#顯示my_collection集合中文檔數(shù)目print (db.my_collection.find().count())#插入10000條文檔信息for i in range(10000):db.my_collection.insert({"id":i,"name":"Licz"})#顯示my_collection集合中文檔數(shù)目print ('插入完畢,當前文檔數(shù)目:')print (db.my_collection.find().count())#執(zhí)行插入[mongod@racdb ~]$ python2.7.3batch_insert.py[u'system.indexes', u'table1',u'my_collection']Collection(Database(MongoClient(host=['racdb:28885'],document_class=dict, tz_aware=False, connect=True), u'testdb'), u'my_collection')0
插入完畢,當前文檔數(shù)目:
10000#或是用mongo shell插入測試數(shù)據(jù)for (var i=1; i<=100000; i++) {db.cc.insert({"id": i,"myName" : "cc"+i, "myDate" : new Date()});}
啟用集合分片
mongos> show collectionsmongos> db.cc.find()mongos> db.cc.createIndex({"id": "hashed" })mongos> db.cc.getIndexes()mongos>sh.shardCollection("testdb.cc", { "id": "hashed"})mongos> db.stats()mongos> db.cc.stats()--查看sharding 狀態(tài)mongos> db.printShardingStatus();
以上內容是小編給大家介紹的MongoDB分片測試,希望對大家有所幫助!
新聞熱點
疑難解答