Merge pull request #2 from senssei/feature/1

Add sharding by location partion

Author: Rafał Warzycha

README.md

@@ -2,10 +2,15 @@
 
 This is a simple 3 node replica mongodb setup based on offcial `mongo` docker image using `docker-compose` described in my blogpost at https://warzycha.pl/mongo-db-sharding-docker-example/.
 
+For details description, steps and discussion go to:
+
+1. https://warzycha.pl/mongo-db-sharding-docker-example/
+2. https://warzycha.pl/mongo-db-location-based-segments/
+
 # Run
 
 ```
->docker-compose -f docker-compose.1.yml -f docker-compose.2.yml  -f docker-compose.cnf.yml -f docker-compose.shard.yml up
+docker-compose -f docker-compose.1.yml -f docker-compose.2.yml  -f docker-compose.cnf.yml -f docker-compose.shard.yml up
 ```
 
 # Tests
@@ -49,6 +54,12 @@ this should return something similar to:
 
 ```
 
+# Sharding configuration
+
+Connect to 'mongos' router and run `queries/shard-status.js` for shard status.
+
+To establish location based partitioning on it just run `queries/init.js`.
+
 # Issues and limitations
 
 It's sometimes stuck on 'mongo-router         | 2017-01-16T21:29:48.573+0000 W NETWORK  [replSetDistLockPinger] No primary detected for

queries/init.js

@@ -0,0 +1,52 @@
+sh.removeShardTag("rs1", "US");
+
+sh.removeShardTag("rs2", "EU");
+
+sh.addShardTag("rs1", "US");
+
+sh.addShardTag("rs2", "EU");
+
+sh.disableBalancing("test.sample");
+
+db.sample.drop();
+
+db.createCollection("sample"); 
+
+db.sample.createIndex( { location: 1, _id: 1 } )
+
+sh.addTagRange(
+  "test.sample",
+  { "location" : "US", "_id" : MinKey },
+  { "location" : "US", "_id" : MaxKey },
+  "US"
+);
+
+sh.addTagRange(
+  "test.sample",
+  { "location" : "EU", "_id" : MinKey },
+  { "location" : "EU", "_id" : MaxKey },
+  "EU"
+)
+
+
+sh.enableSharding("test");
+
+sh.shardCollection("test.sample",{ location: 1, _id: 1 });
+
+sh.enableBalancing("test.sample");
+
+db.sample.insert({
+    "_id" : ObjectId("5787936b94afebe02398521a"),
+    "location": "US",
+    "__v" : 0
+});
+
+db.sample.insert({
+    "_id" : ObjectId("5787a08c94afebe023985224"),
+    "location": "EU",
+    "__v" : 0
+});
+
+sh.startBalancer();
+
+db.sample.find();

queries/shard-status.js

@@ -0,0 +1 @@
+sh.status();