MongoDb unable to insert documents using Java Driver in sharded env -

-

when try connect mongo db sharded @ key "state" via jdbc, , insert document, says missing shardkey

my shards (2 no, part of individual replica sets) , config servers (1 no, part of replica set)are , running, , can insert document using mongos terminal, cant insert documents using java driver. mongodb version 2.6.5. 

package dao;  import util.instancefactory;  import com.mongodb.db; import com.mongodb.mongoclient; import org.apache.log4j.logger;  public class mongoconnector {  private static mongoconnector mongoconnectorinstance;  private db dbconnection;  public static db getconnection(string dbname) {    mongoconnector.mongoconnectorinstance = instancefactory.instantiateassingleton(mongoconnector.class);    if (mongoconnector.mongoconnectorinstance.dbconnection == null) {      synchronized (mongoconnector.mongoconnectorinstance) {        if (mongoconnector.mongoconnectorinstance.dbconnection == null) {         mongoconnector.mongoconnectorinstance.dbconnection = mongoconnector.mongoconnectorinstance .getdbconnection(dbname);       }     }   }    return mongoconnector.mongoconnectorinstance.dbconnection;  }  private db getdbconnection(string dbname) {    db db = null;    try {      mongoclient mongoclient = new mongoclient("some ip address of mongos", 27017);     // connect databases    db = mongoclient.getdb(dbname);     system.out.println("connect database successfully");    } catch (exception e) {     system.err.println(e.getclass().getname() + ": " + e.getmessage());   }    return db;   } }

now when try insert document using other class below function shard key not present code 61

 public static boolean insert(dbobject object, string table) {     boolean status = false;     if (object != null) {         try {             db db = mongoconnector.getconnection("somedb");             dbcollection collection = db.getcollection(table);             //system.out.println(collection);             if (collection == null) {                 db.createcollection(table, null);             }             collection.insert(object);             status = true;         } catch (exception e) {             mongodao.logger.error("could not insert in database" + e);         }     }     return status; }

my object inserted looks 

dbobject o=new basicdbobject("somecolumn":"somevalue")            .append("shardkey":"up"); mongodao.insert(o,"sometable");

am missing configuartion connect shards?

if shard key state, problem construction of document:

dbobject o = new basicdbobject("somecolumn" : "somevalue")     .append("shardkey" : "up");

it should like

dbobject o = new basicdbobject("somecolumn" : "somevalue")     .append("state" : "up");

it looks did not set shard key correctly.

also, couple of other notes sharding setup:

  1. you said have 1 config server. use 3. not use 1 config server, ever, except small test deployments don't care @ all. use 3 config servers.

  2. you said shard key has 36 possible values. few. 36 possible values, can have @ 36 possible chunks distributed between shards. small number of potential chunks make hard or impossible mongodb balance amount of data between shards. need reconsider shard key. choosing shard key critical part of scaling mongodb deployment , making right choice requires lot of knowledge system's use case; can start some advice on choosing shard keys manual.


Comments

Post a Comment

Popular posts from this blog

matlab - "Contour not rendered for non-finite ZData" -

-
i'm trying plot frequency characteristic equation using ezplot, matlab gives following warning, "contour not rendered non-finite zdata". have used command plot frequency equations warning , plot display empty , not change axis range well. can please help. appreciated. here's code i'm using. % transfer matrix case-i, thin rotor clear all; clc; ei = 1626; l = 0.15; m = 0.44108; = 2.178*10^-4; i_p = 2.205*10^-5; itr = 0.24; i_pr = 0.479; syms p n; f = [1 l*1i l^2/(2*ei)*1i l^3/(6*ei); 0 1 l/ei -l^2/(2*ei)*1i; 0 0 1 -l*1i; 0 0 0 l]; p = [ 1 0 0 0; 0 1 0 0; 0 -it*p^2+i_p*n*p 1 0; -m*p^2 0 0 1]; p_r = [1 0 0 0; 0 1 0 0; 0 -itr*p^2+i_pr*n*p 1 0; -m*p^2 0 0 1]; = f*p*f*p*f*p*f; b = p_r*f*p*f*p*f; r = a(1,2)/a(1,4); a12_p = 0; a22_p = a(2,2)-r*a(2,4); a32_p = a(3,2)-r*a(3,4); a42_p = a(4,2)-r*a(4,4); ap(2,2) = a22_p; ap(3,2) = a32_p; ap(4,2) = a42_p; ap(4,4) = 1; c = b*ap; m = [c(3,2) c(3,4); c(4,2) c(4,...
Read more

delphi - Indy UDP Read Contents of Adata -

-
i using indy udp server read string of data. however, not know how work adata parameter. can around converting binary using bytetobin function below , convert hex using bintohex1 . feel stupid , works slow. know how can directly results without 2 conversions? thanks!! here codes: procedure tform1.idudpserver1udpread(athread: tidudplistenerthread; const adata: tidbytes; abinding: tidsockethandle); var buf: tidbytes; buffer: string; data_received: string; begin if bytestostring(adata) <> 'hello' begin buffer := hextostring('00'); setlength(buf, length(buffer)); copytidstring(buffer, buf, 0); abinding.sendto(abinding.peerip, abinding.peerport, buf); data_received := bintohex1(bytetobin(adata[1]) + bytetobin(adata[2]) + bytetobin(adata[3]) + bytetobin(adata[4]) + bytetobin(adata[5]) + bytetobin(adata[6]) + bytetobin(adata[7]) + bytetobin(adata[8]) + bytetobin(adata[9]) + bytetobin(adata[10]) + bytetobin(adata[11...
Read more

javascript - Any ideas when Firefox is likely to implement lengthAdjust and textLength? -

-
any ideas when firefox implement lengthadjust andtextlength?..... working svg application. lengthadjust , textlength working fine in chrome not working in fire fox . <svg viewbox = "0 0 500 300" version = "1.1"> <defs> <path id="s3" d="m 10,90 q 100,15 200,70" /> </defs> <g> <text font-size = "20"> <textpath xlink:href="#s3" textlength="205"> short text</textpath> </text> <use xlink:href="#s3" fill="none" stroke="black" stroke-width="1"/> </g> </svg> this implemented in firefox text elements (not textpath or tspan) in case that's ok though can move attribute text element. <svg viewbox = "0 0 500 300" version = "1.1"> <defs> ...
Read more