av久久在线观看,6080私人午夜性爽快影院,caoporn成人

主頁 > 知識庫 > 如何為MongoDB添加分片副本集

如何為MongoDB添加分片副本集

01 新建副本集

由于我們即將加入集群的分片是一個副本集，因此，需要提前將這個副本集創建好，創建的過程相對比較容易，按照之前的步驟來進行搭建，這里給出鏈接：

MongoDB 副本集的搭建

02 副本集添加到已有的集群中(addShard)

這一步也比較簡單，可以直接在mongos上的admin數據庫使用命令addShard即可：

db.runCommand({addShard:"sharding_yeyz1/127.0.0.1:27024,127.0.0.1:27025,127.0.0.1:27026"})

當然，你也可以直接使用db.adminCommand命令來代替db.runCommand命令，這兩個命令的區別是adminCommand命令默認是在admin數據庫下面執行的，而runCommand默認的是當前數據庫。

上面的命令，將本地的：

27024、27025、27026端口加入到集群中。到這里架構會變成：

03 添加分片時間標簽(addShardTag)

分片加入到集群之后，還需要對分片添加Tag，添加Tag的目的，是讓我們知道，當前分片上保留的業務數據是哪一個時間段的。在測試環境中，我使用1_1000和1000_2000這兩個tag來測試，命令如下：

sh.addShardTag("sharding_yeyz", "1_1000")
sh.addShardTag("sharding_yeyz1", "1000_2000")

對上面的命令簡單進行解釋，其中：

sharding_yeyz和sharding_yeyz1是分片副本集的名稱；

1_1000和1000_2000是tag的名稱。

添加完畢之后，我們可以通過系統的config庫下面的tag表看到tag的情況，如下：

mongos> db.shards.find()
{ "_id" : "sharding_yeyz", "host" : "sharding_yeyz/127.0.0.1:27018,127.0.0.1:27019,127.0.0.1:27020", "state" : 1, "tags" : [ "1_1000" ] }
{ "_id" : "sharding_yeyz1", "host" : "sharding_yeyz1/127.0.0.1:27024,127.0.0.1:27025,127.0.0.1:27026", "state" : 1, "tags" : [ "1000_2000" ] }

04 給打好的標簽添加具體的數值范圍(addTagRange)

設定好標簽之后，需要設置每個標簽所代表的分片上具體的數值范圍，這就要用到addTagRange函數，使用方法如下：

sh.addTagRange( "new.test",
  { number: 1},
  { number: 1000},
  "1_1000"
  )
sh.addTagRange( "new.test",
  { number: 1000},
  { number: 2000},
  "1000_2000"
  )

注意，這里數值范圍是指分片的那個集合的片鍵的數值范圍。

分片永遠是針對集合說的。

上面的命令是說，我們對數據庫new下面的test集合做了分片，它的片鍵值是number這個字段：

當number屬于[1,1000）的時候，該文檔存放在tag是"1_1000"的這個分片上,也就是sharding_yeyz；

當number屬于[1000,2000）的時候，該文檔存放在tag是"1000_2000"的這個分片上,也就是sharding_yeyz1；

注意，區間為左閉右開。

05 查看結果

添加分片并設置分片的數值范圍之后，我們可以使用：

db.printShardingStatus()命令或者sh.status()命令來查看當前集群中的分片情況：

mongos> sh.status()
--- Sharding Status --- 
 sharding version: {
 "_id" : 1,
 "minCompatibleVersion" : 5,
 "currentVersion" : 6,
 "clusterId" : ObjectId("5fafaf4f5785d9965548f687")
 }
 shards:
 { "_id" : "sharding_yeyz", "host" : "sharding_yeyz/127.0.0.1:27018,127.0.0.1:27019,127.0.0.1:27020", "state" : 1, "tags" : [ "1_1000" ] }
 { "_id" : "sharding_yeyz1", "host" : "sharding_yeyz1/127.0.0.1:27024,127.0.0.1:27025,127.0.0.1:27026", "state" : 1, "tags" : [ "1000_", "1000_2000" ] }
 active mongoses:
 "4.0.6" : 1
 autosplit:
 Currently enabled: yes
 balancer:
 Currently enabled: yes
 Currently running: no
 Failed balancer rounds in last 5 attempts: 0
 Migration Results for the last 24 hours: 
  No recent migrations
 databases:
 { "_id" : "config", "primary" : "config", "partitioned" : true }
  config.system.sessions
   shard key: { "_id" : 1 }
   unique: false
   balancing: true
   chunks:
    sharding_yeyz 1
   { "_id" : { "$minKey" : 1 } } -->> { "_id" : { "$maxKey" : 1 } } on : sharding_yeyz Timestamp(1, 0) 
 { "_id" : "new", "primary" : "sharding_yeyz", "partitioned" : true, "version" : { "uuid" : UUID("68c70c64-f732-4478-8851-06dad4b94d6b"), "lastMod" : 1 } }
  new.test
   shard key: { "number" : 1 }
   unique: false
   balancing: true
   chunks:
    sharding_yeyz 3
    sharding_yeyz1 1
   { "number" : { "$minKey" : 1 } } -->> { "number" : 1 } on : sharding_yeyz Timestamp(2, 1) 
   { "number" : 1 } -->> { "number" : 1000 } on : sharding_yeyz Timestamp(1, 2) 
   { "number" : 1000 } -->> { "number" : 2000 } on : sharding_yeyz1 Timestamp(2, 0) 
   { "number" : 2000 } -->> { "number" : { "$maxKey" : 1 } } on : sharding_yeyz Timestamp(1, 5) 
    tag: 1_1000 { "number" : 1 } -->> { "number" : 1000 }
    tag: 1000_2000 { "number" : 1000 } -->> { "number" : 2000 }

到了這里，我們開始驗證最終的結果，先通過下面的命令生成一組測試數據，如下：

for (var i=1 ;i=2000 ; i++){ db.test.insert({"number":i})}

去查看每個分片上的內容，可以發現：

sharding_yeyz

sharding_yeyz:PRIMARY> db.test.find().sort({"number":-1})
{ "_id" : ObjectId("5ffc051dd4c416daac620af5"), "number" : 2000 }
{ "_id" : ObjectId("5ffc0511d4c416daac620325"), "number" : 2000 }
{ "_id" : ObjectId("5ffc051bd4c416daac62070c"), "number" : 999 }
{ "_id" : ObjectId("5ffc050fd4c416daac61ff3c"), "number" : 999 }
{ "_id" : ObjectId("5ffc051bd4c416daac62070b"), "number" : 998 }
{ "_id" : ObjectId("5ffc050fd4c416daac61ff3b"), "number" : 998 }
{ "_id" : ObjectId("5ffc051bd4c416daac62070a"), "number" : 997 }
{ "_id" : ObjectId("5ffc050fd4c416daac61ff3a"), "number" : 997 }
{ "_id" : ObjectId("5ffc051bd4c416daac620709"), "number" : 996 }
{ "_id" : ObjectId("5ffc050fd4c416daac61ff39"), "number" : 996 }
{ "_id" : ObjectId("5ffc051bd4c416daac620708"), "number" : 995 }

這里需要注意，為什么2000這個值還是出現在分片一上呢？

這個原因是在設置分片的數值范圍的時候，我們設置的區間是左閉右開的。而我們設置的分片范圍分別是[1,1000）和[1000,2000）,因此2000這個數字就被隨機分配到這兩個分片中，實際的情況是，它被分配到了分片一中。

sharding_yeyz1

sharding_yeyz1:PRIMARY> db.test.find().sort({"number":-1})
{ "_id" : ObjectId("5ffc051dd4c416daac620af4"), "number" : 1999 }
{ "_id" : ObjectId("5ffc0511d4c416daac620324"), "number" : 1999 }
{ "_id" : ObjectId("5ffc051dd4c416daac620af3"), "number" : 1998 }
{ "_id" : ObjectId("5ffc0511d4c416daac620323"), "number" : 1998 }
{ "_id" : ObjectId("5ffc051dd4c416daac620af2"), "number" : 1997 }
{ "_id" : ObjectId("5ffc0511d4c416daac620322"), "number" : 1997 }
{ "_id" : ObjectId("5ffc051dd4c416daac620af1"), "number" : 1996 }
{ "_id" : ObjectId("5ffc0511d4c416daac620321"), "number" : 1996 }
{ "_id" : ObjectId("5ffc051dd4c416daac620af0"), "number" : 1995 }
{ "_id" : ObjectId("5ffc0511d4c416daac620320"), "number" : 1995 }
{ "_id" : ObjectId("5ffc051dd4c416daac620aef"), "number" : 1994 }
{ "_id" : ObjectId("5ffc0511d4c416daac62031f"), "number" : 1994 }
{ "_id" : ObjectId("5ffc051dd4c416daac620aee"), "number" : 1993 }
{ "_id" : ObjectId("5ffc0511d4c416daac62031e"), "number" : 1993 }
{ "_id" : ObjectId("5ffc051dd4c416daac620aed"), "number" : 1992 }
{ "_id" : ObjectId("5ffc0511d4c416daac62031d"), "number" : 1992 }

這個結果看著就比較正常了。

今天的內容就到這里吧。

以上就是如何為MongoDB添加分片副本集的詳細內容，更多關于為MongoDB添加分片副本集的資料請關注腳本之家其它相關文章！

您可能感興趣的文章: