MongoDB对集合分片

1 创建数据库，直接use database_name 切换至你想创建的数据库。

mongos> use DataPlatform
switched to db DataPlatform

2 创建集合 

mongos> db.createCollection("risk_dag_hive_to_mongo", {"autoIndexId":true})
{
"note" : "the autoIndexId option is deprecated and will be removed in a future release",
"ok" : 1
}

3 首先要对库DataPlatform开启分片功能

mongos> sh.enableSharding("DataPlatform");
{ "ok" : 1 }

可以通过 命令验证

sh.status()

4 对集合开启分片 

mongos>  sh.shardCollection("DataPlatform.risk_dag_hive_to_mongo",{"user_id":1})
{ "collectionsharded" : "DataPlatform.risk_dag_hive_to_mongo", "ok" : 1 }

通过命令验证  看截图中sharded已经为true，说明开启了分片

mongos> db.risk_dag_hive_to_mongo.stats()

5 为数据库创建账号 

mongos>  db.createUser(
...      {
...        user:"DataPlatform_rw",
...        pwd:"",
...        roles:[{role:"readWrite",db:"DataPlatform"}]
...      })
Successfully added user: {
"user" : "DataPlatform_rw",
"roles" : [
{
"role" : "readWrite",
"db" : "DataPlatform"
}
]
}