Advertisement
Guest User

Untitled

a guest
Dec 12th, 2019
93
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 11.56 KB | None | 0 0
  1. #config server
  2.  
  3. mongod --configsvr --port 27020 --dbpath=data\config --replSet confSet
  4.  
  5. mongo --port 27020
  6.  
  7. rs.initiate(
  8. {
  9. _id: "confSet",
  10. configsvr: true,
  11. members: [
  12. { _id : 0, host : "127.0.0.1:27020" }
  13. ]
  14. }
  15. )
  16.  
  17.  
  18. # shardy 1, 2 i 3
  19. #tylko mongod i nic wiecej
  20.  
  21. mongod --shardsvr --replSet shard1Set --dbpath=data\sh1 --port 27021
  22. mongo port --port 27021
  23. rs.initiate({_id:"shard1Set", members:[{_id:0, host:"127.0.0.1:27021"}]})
  24.  
  25. mongod --shardsvr --replSet shard2Set --dbpath=data\sh2 --port 27022
  26. mongo port --port 27022
  27. rs.initiate({_id:"shard2Set", members:[{_id:0, host:"127.0.0.1:27022"}]})
  28.  
  29. mongod --shardsvr --replSet shard3Set --dbpath=data\sh3 --port 27023
  30. mongo port --port 27023
  31. rs.initiate({_id:"shard3Set", members:[{_id:0, host:"127.0.0.1:27023"}]})
  32.  
  33.  
  34. #router
  35. mongos --configdb confSet/127.0.0.1:27020 --port 27017
  36. cmd > mongo
  37. sh.addShard("shard1Set/127.0.0.1:27021")
  38. sh.addShard("shard2Set/127.0.0.1:27022")
  39. sh.addShard("shard3Set/127.0.0.1:27023")
  40.  
  41. sh.enableSharding("ourBase")
  42. use ourBase
  43. sh.status() #primary: shard2Set
  44.  
  45.  
  46. # utworz repliki ( w tym przypadku shard2Set )
  47. mongod --port 27014 --dbpath .\data\arb1 --replSet shard2Set
  48. mongod --port 27015 --dbpath .\data\ord1 --replSet shard2Set
  49.  
  50.  
  51. #laczymy sie z shard2Set (27022)
  52. #dodajemy ordinary i arbiter
  53. rs.add("127.0.0.1:27015")
  54. rs.addArb("127.0.0.1:27014")
  55.  
  56.  
  57. #dodanie unsharded
  58. cmd > mongo
  59. db.col1.insert({a:"aaa", b:"bbb", d:5})
  60. db.col1.insert({a:"eee", b:"fff", d:5})
  61. db.col1.insert({a:"iii", b:"jjj", d:"z"})
  62. db.col1.insert({a:"eee", b:"fff"})
  63. db.col1.insert({a:"nnn", b:"ooo"})
  64.  
  65.  
  66. #dodanie hashed
  67. sh.shardCollection("ourBase.col3",{pole:"hashed"})
  68. db.col3.insert({pole:"a"})
  69. db.col3.insert({pole:"b"})
  70. db.col3.insert({pole:"c"})
  71. db.col3.insert({pole:"d"})
  72. db.col3.insert({pole:"e"})
  73. db.col3.insert({pole:"f"})
  74. db.col3.insert({pole:"g"})
  75. db.col3.insert({pole:"h"})
  76. db.col3.insert({pole:"i"})
  77. db.col3.insert({pole:"j"})
  78. db.col3.insert({pole:"k"})
  79. db.col3.insert({pole:"l"})
  80. db.col3.insert({pole:"m"})
  81. db.col3.insert({pole:"n"})
  82. db.col3.insert({pole:"o"})
  83. db.col3.insert({pole:"u"})
  84. db.col3.insert({pole:"p"})
  85.  
  86. #dodanie danych shardowanych miedzy 2 servery primary (shard1Set, shard3Set)
  87. sh.addShardToZone("shard1Set","zadanie")
  88. sh.addShardToZone("shard3Set","zadanie")
  89.  
  90.  
  91. #ODPOWIEDZI:
  92. ##result of rs.status() command of the primary shard:
  93. shard2Set:PRIMARY> rs.status()
  94. {
  95. "set" : "shard2Set",
  96. "date" : ISODate("2019-12-12T14:42:57.614Z"),
  97. "myState" : 1,
  98. "term" : NumberLong(1),
  99. "syncingTo" : "",
  100. "syncSourceHost" : "",
  101. "syncSourceId" : -1,
  102. "heartbeatIntervalMillis" : NumberLong(2000),
  103. "majorityVoteCount" : 2,
  104. "writeMajorityCount" : 2,
  105. "optimes" : {
  106. "lastCommittedOpTime" : {
  107. "ts" : Timestamp(1576161776, 1),
  108. "t" : NumberLong(1)
  109. },
  110. "lastCommittedWallTime" : ISODate("2019-12-12T14:42:56.225Z"),
  111. "readConcernMajorityOpTime" : {
  112. "ts" : Timestamp(1576161776, 1),
  113. "t" : NumberLong(1)
  114. },
  115. "readConcernMajorityWallTime" : ISODate("2019-12-12T14:42:56.225Z"),
  116. "appliedOpTime" : {
  117. "ts" : Timestamp(1576161776, 1),
  118. "t" : NumberLong(1)
  119. },
  120. "durableOpTime" : {
  121. "ts" : Timestamp(1576161776, 1),
  122. "t" : NumberLong(1)
  123. },
  124. "lastAppliedWallTime" : ISODate("2019-12-12T14:42:56.225Z"),
  125. "lastDurableWallTime" : ISODate("2019-12-12T14:42:56.225Z")
  126. },
  127. "lastStableRecoveryTimestamp" : Timestamp(1576161746, 1),
  128. "lastStableCheckpointTimestamp" : Timestamp(1576161746, 1),
  129. "electionCandidateMetrics" : {
  130. "lastElectionReason" : "electionTimeout",
  131. "lastElectionDate" : ISODate("2019-12-12T14:11:24.995Z"),
  132. "termAtElection" : NumberLong(1),
  133. "lastCommittedOpTimeAtElection" : {
  134. "ts" : Timestamp(0, 0),
  135. "t" : NumberLong(-1)
  136. },
  137. "lastSeenOpTimeAtElection" : {
  138. "ts" : Timestamp(1576159884, 1),
  139. "t" : NumberLong(-1)
  140. },
  141. "numVotesNeeded" : 1,
  142. "priorityAtElection" : 1,
  143. "electionTimeoutMillis" : NumberLong(10000),
  144. "newTermStartDate" : ISODate("2019-12-12T14:11:26.047Z"),
  145. "wMajorityWriteAvailabilityDate" : ISODate("2019-12-12T14:11:26.111Z")
  146. },
  147. "members" : [
  148. {
  149. "_id" : 0,
  150. "name" : "127.0.0.1:27022",
  151. "ip" : "127.0.0.1",
  152. "health" : 1,
  153. "state" : 1,
  154. "stateStr" : "PRIMARY",
  155. "uptime" : 1902,
  156. "optime" : {
  157. "ts" : Timestamp(1576161776, 1),
  158. "t" : NumberLong(1)
  159. },
  160. "optimeDate" : ISODate("2019-12-12T14:42:56Z"),
  161. "syncingTo" : "",
  162. "syncSourceHost" : "",
  163. "syncSourceId" : -1,
  164. "infoMessage" : "",
  165. "electionTime" : Timestamp(1576159885, 1),
  166. "electionDate" : ISODate("2019-12-12T14:11:25Z"),
  167. "configVersion" : 3,
  168. "self" : true,
  169. "lastHeartbeatMessage" : ""
  170. },
  171. {
  172. "_id" : 1,
  173. "name" : "127.0.0.1:27015",
  174. "ip" : "127.0.0.1",
  175. "health" : 1,
  176. "state" : 2,
  177. "stateStr" : "SECONDARY",
  178. "uptime" : 954,
  179. "optime" : {
  180. "ts" : Timestamp(1576161766, 1),
  181. "t" : NumberLong(1)
  182. },
  183. "optimeDurable" : {
  184. "ts" : Timestamp(1576161766, 1),
  185. "t" : NumberLong(1)
  186. },
  187. "optimeDate" : ISODate("2019-12-12T14:42:46Z"),
  188. "optimeDurableDate" : ISODate("2019-12-12T14:42:46Z"),
  189. "lastHeartbeat" : ISODate("2019-12-12T14:42:56.184Z"),
  190. "lastHeartbeatRecv" : ISODate("2019-12-12T14:42:57.244Z"),
  191. "pingMs" : NumberLong(0),
  192. "lastHeartbeatMessage" : "",
  193. "syncingTo" : "127.0.0.1:27022",
  194. "syncSourceHost" : "127.0.0.1:27022",
  195. "syncSourceId" : 0,
  196. "infoMessage" : "",
  197. "configVersion" : 3
  198. },
  199. {
  200. "_id" : 2,
  201. "name" : "127.0.0.1:27014",
  202. "ip" : "127.0.0.1",
  203. "health" : 1,
  204. "state" : 7,
  205. "stateStr" : "ARBITER",
  206. "uptime" : 948,
  207. "lastHeartbeat" : ISODate("2019-12-12T14:42:56.144Z"),
  208. "lastHeartbeatRecv" : ISODate("2019-12-12T14:42:56.284Z"),
  209. "pingMs" : NumberLong(0),
  210. "lastHeartbeatMessage" : "",
  211. "syncingTo" : "",
  212. "syncSourceHost" : "",
  213. "syncSourceId" : -1,
  214. "infoMessage" : "",
  215. "configVersion" : 3
  216. }
  217. ],
  218. "ok" : 1,
  219. "$gleStats" : {
  220. "lastOpTime" : {
  221. "ts" : Timestamp(1576160829, 1),
  222. "t" : NumberLong(1)
  223. },
  224. "electionId" : ObjectId("7fffffff0000000000000001")
  225. },
  226. "lastCommittedOpTime" : Timestamp(1576161776, 1),
  227. "$configServerState" : {
  228. "opTime" : {
  229. "ts" : Timestamp(1576161768, 2),
  230. "t" : NumberLong(1)
  231. }
  232. },
  233. "$clusterTime" : {
  234. "clusterTime" : Timestamp(1576161776, 1),
  235. "signature" : {
  236. "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
  237. "keyId" : NumberLong(0)
  238. }
  239. },
  240. "operationTime" : Timestamp(1576161776, 1)
  241. }
  242.  
  243. ##result of sh.status() command for the database (router):
  244. mongos> sh.status()
  245. --- Sharding Status ---
  246. sharding version: {
  247. "_id" : 1,
  248. "minCompatibleVersion" : 5,
  249. "currentVersion" : 6,
  250. "clusterId" : ObjectId("5df24a5ce59a5d294a1da34b")
  251. }
  252. shards:
  253. { "_id" : "shard1Set", "host" : "shard1Set/127.0.0.1:27021", "state" : 1, "tags" : [ "zadanie" ] }
  254. { "_id" : "shard2Set", "host" : "shard2Set/127.0.0.1:27015,127.0.0.1:27022", "state" : 1 }
  255. { "_id" : "shard3Set", "host" : "shard3Set/127.0.0.1:27023", "state" : 1, "tags" : [ "zadanie" ] }
  256. active mongoses:
  257. "4.2.1" : 1
  258. autosplit:
  259. Currently enabled: yes
  260. balancer:
  261. Currently enabled: yes
  262. Currently running: no
  263. Failed balancer rounds in last 5 attempts: 0
  264. Migration Results for the last 24 hours:
  265. No recent migrations
  266. databases:
  267. { "_id" : "config", "primary" : "config", "partitioned" : true }
  268. config.system.sessions
  269. shard key: { "_id" : 1 }
  270. unique: false
  271. balancing: true
  272. chunks:
  273. shard1Set 1
  274. { "_id" : { "$minKey" : 1 } } -->> { "_id" : { "$maxKey" : 1 } } on : shard1Set Timestamp(1, 0)
  275. { "_id" : "ourBase", "primary" : "shard2Set", "partitioned" : true, "version" : { "uuid" : UUID("86c6ec5b-c836-49d0-a41e-381f498e30a9"), "lastMod" : 1 } }
  276. ourBase.col3
  277. shard key: { "pole" : "hashed" }
  278. unique: false
  279. balancing: true
  280. chunks:
  281. shard1Set 2
  282. shard2Set 2
  283. shard3Set 2
  284. { "pole" : { "$minKey" : 1 } } -->> { "pole" : NumberLong("-6148914691236517204") } on : shard1Set Timestamp(1, 0)
  285. { "pole" : NumberLong("-6148914691236517204") } -->> { "pole" : NumberLong("-3074457345618258602") } on : shard1Set Timestamp(1, 1)
  286. { "pole" : NumberLong("-3074457345618258602") } -->> { "pole" : NumberLong(0) } on : shard2Set Timestamp(1, 2)
  287. { "pole" : NumberLong(0) } -->> { "pole" : NumberLong("3074457345618258602") } on : shard2Set Timestamp(1, 3)
  288. { "pole" : NumberLong("3074457345618258602") } -->> { "pole" : NumberLong("6148914691236517204") } on : shard3Set Timestamp(1, 4)
  289. { "pole" : NumberLong("6148914691236517204") } -->> { "pole" : { "$maxKey" : 1 } } on : shard3Set Timestamp(1, 5)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement