目錄
- 01 新建副本集
- 02 副本集添加到已有的集群中(addShard)
- 03 添加分片時間標(biāo)簽(addShardTag)
- 04 給打好的標(biāo)簽添加具體的數(shù)值范圍(addTagRange)
- 05 查看結(jié)果
背景是這樣的：線上一個MongoDB集群保存了很多歷史數(shù)據(jù)，這些歷史數(shù)據(jù)是按照時間字段進(jìn)行分片的，最近到了2021年，有些分片的截止時間要到了，為了能容納更多的數(shù)據(jù)，需要在當(dāng)前分片的基礎(chǔ)上增加相應(yīng)的分片。
線上環(huán)境中，每個分片本身也是一個3副本的副本集，所以添加的時候有些特定的流程需要注意，我再測試環(huán)境中簡單測了一下這個過程，記錄下來。
整個過程大概的流程是：
1、新建分片副本集
2、使用addShard命令將分片副本集添加到集群中
3、使用addShardTag命令為分片打標(biāo)簽
4、使用addTagRange命令為打好標(biāo)簽的分片設(shè)置片鍵的數(shù)值區(qū)間，注意，各個分片的數(shù)值區(qū)間不能有重復(fù)。
目前測試環(huán)境的架構(gòu)是：
01 新建副本集
由于我們即將加入集群的分片是一個副本集，因此，需要提前將這個副本集創(chuàng)建好，創(chuàng)建的過程相對比較容易，按照之前的步驟來進(jìn)行搭建，這里給出鏈接：
MongoDB 副本集的搭建
02 副本集添加到已有的集群中(addShard)
這一步也比較簡單，可以直接在mongos上的admin數(shù)據(jù)庫使用命令addShard即可：
db.runCommand({addShard:"sharding_yeyz1/127.0.0.1:27024,127.0.0.1:27025,127.0.0.1:27026"})
當(dāng)然，你也可以直接使用db.adminCommand命令來代替db.runCommand命令，這兩個命令的區(qū)別是adminCommand命令默認(rèn)是在admin數(shù)據(jù)庫下面執(zhí)行的，而runCommand默認(rèn)的是當(dāng)前數(shù)據(jù)庫。
上面的命令，將本地的：
27024、27025、27026端口加入到集群中。到這里架構(gòu)會變成：
03 添加分片時間標(biāo)簽(addShardTag)
分片加入到集群之后，還需要對分片添加Tag，添加Tag的目的，是讓我們知道，當(dāng)前分片上保留的業(yè)務(wù)數(shù)據(jù)是哪一個時間段的。在測試環(huán)境中，我使用1_1000和1000_2000這兩個tag來測試，命令如下：
sh.addShardTag("sharding_yeyz", "1_1000")
sh.addShardTag("sharding_yeyz1", "1000_2000")
對上面的命令簡單進(jìn)行解釋，其中：
sharding_yeyz和sharding_yeyz1是分片副本集的名稱；
1_1000和1000_2000是tag的名稱。
添加完畢之后，我們可以通過系統(tǒng)的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 給打好的標(biāo)簽添加具體的數(shù)值范圍(addTagRange)
設(shè)定好標(biāo)簽之后，需要設(shè)置每個標(biāo)簽所代表的分片上具體的數(shù)值范圍，這就要用到addTagRange函數(shù)，使用方法如下：
sh.addTagRange( "new.test",
{ number: 1},
{ number: 1000},
"1_1000"
)
sh.addTagRange( "new.test",
{ number: 1000},
{ number: 2000},
"1000_2000"
)
注意，這里數(shù)值范圍是指分片的那個集合的片鍵的數(shù)值范圍。
分片永遠(yuǎn)是針對集合說的。
上面的命令是說，我們對數(shù)據(jù)庫new下面的test集合做了分片，它的片鍵值是number這個字段：
當(dāng)number屬于[1,1000）的時候，該文檔存放在tag是"1_1000"的這個分片上,也就是sharding_yeyz；
當(dāng)number屬于[1000,2000）的時候，該文檔存放在tag是"1000_2000"的這個分片上,也就是sharding_yeyz1；
注意，區(qū)間為左閉右開。
05 查看結(jié)果
添加分片并設(shè)置分片的數(shù)值范圍之后，我們可以使用：
db.printShardingStatus()命令或者sh.status()命令來查看當(dāng)前集群中的分片情況：
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 }
到了這里，我們開始驗(yàn)證最終的結(jié)果，先通過下面的命令生成一組測試數(shù)據(jù)，如下：
for (var i=1 ;i=2000 ; i++){ db.test.insert({"number":i})}
去查看每個分片上的內(nèi)容，可以發(fā)現(xiàn)：
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這個值還是出現(xiàn)在分片一上呢？
這個原因是在設(shè)置分片的數(shù)值范圍的時候，我們設(shè)置的區(qū)間是左閉右開的。而我們設(shè)置的分片范圍分別是[1,1000）和[1000,2000）,因此2000這個數(shù)字就被隨機(jī)分配到這兩個分片中，實(shí)際的情況是，它被分配到了分片一中。
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 }
這個結(jié)果看著就比較正常了。
今天的內(nèi)容就到這里吧。
以上就是如何為MongoDB添加分片副本集的詳細(xì)內(nèi)容，更多關(guān)于為MongoDB添加分片副本集的資料請關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:- 分布式文檔存儲數(shù)據(jù)庫之MongoDB分片集群的問題
- MongoDB搭建高可用集群的完整步驟（3個分片+3個副本）
- Mongodb副本集和分片示例詳解
- MongoDB分片集群部署詳解
- MongoDB分片在部署與維護(hù)管理中常見的事項總結(jié)大全
- 詳解MongoDB4.0構(gòu)建分布式分片群集
- MongoDB分片鍵的選擇和案例實(shí)例詳解
- MongoDB分片詳解
- mongodb分片技術(shù)_動力節(jié)點(diǎn)Java學(xué)院整理
- mongodb3.4集群搭建實(shí)戰(zhàn)之高可用的分片+副本集
- 深入理解MongoDB分片的管理
- Mongodb 刪除添加分片與非分片表維護(hù)
- MongoDB 主分片(primary shard)相關(guān)總結(jié)
