Qual è il modo più efficace di inserire più righe nella famiglia di colonne cassandra. È possibile farlo in una singola chiamata.Come inserire più righe in cassandra
In questo momento il mio approccio consiste nell'aggiungere più colonne e quindi eseguirle. Lì in una sola chiamata sto persistendo una riga. Sto cercando una strategia in modo da poter inserire un batch.
è possibile aggiungere le istruzioni multiple inserite in un file ed eseguire il file con 'cqlsh -f'.
è inoltre possibile eseguire inserto batch con CQL in Cassandra, come descritto nel seguito link: http://www.datastax.com/documentation/cassandra/1.2/index.html#cassandra/cql_reference/batch_r.html
C'è un'operazione di inserimento dei lotti a Cassandra. È possibile raggruppare insieme inserti, anche in famiglie di colonne diverse, per rendere l'inserimento più efficiente.
In Hector, è possibile utilizzare HFactory.createMutator quindi utilizzare i metodi add sul Mutator restituito per aggiungere operazioni al batch. Quando sei pronto, chiama il numero execute().
Se si utilizza CQL, si raggruppano gli elementi in un batch avviando il batch con BEGIN BATCH e terminando con APPLY BATCH.
Assicurati di capire quando questa è una buona idea e [quando non lo è] (http://docs.datastax.com/en/cql/3.1/cql/cql_using/useBatch.html). I batch generalmente non migliorano le prestazioni e possono addirittura ridurli nel peggiore dei casi. Se non hai bisogno di scritture atomiche, assicurati di utilizzare un batch non loggato. –
Buon punto. Penso che i lotti di risparmio abbiano quasi sempre aiutato (a causa del massiccio sovraccarico del risparmio). In CQL, è necessario utilizzare inserimenti asincroni e istruzioni preparate anziché batch. Tranne il caso in cui i tuoi inserti sono tutti sulla stessa partizione, nel qual caso i lotti sono più efficienti. – Richard
CQL viene fornito con un'istruzione BEGIN BATCH ... APPLY BATCH che consente di raggruppare più inserti, in modo che uno sviluppatore possa creare una stringa di tale richiesta batch ed eseguirla. [http://www.datastax.com/dev/blog/client-side-improvements-in-cassandra-2-0]
Di seguito ha lavorato per me:
PreparedStatement ps = session.prepare(
"BEGIN BATCH" +
"INSERT INTO messages (user_id, msg_id, title, body) VALUES (?, ?, ?, ?);" +
"INSERT INTO messages (user_id, msg_id, title, body) VALUES (?, ?, ?, ?);" +
"INSERT INTO messages (user_id, msg_id, title, body) VALUES (?, ?, ?, ?);" +
"APPLY BATCH");
session.execute(ps.bind(uid, mid1, title1, body1, uid, mid2, title2, body2, uid, mid3, title3, body3));
Se non si conosce in anticipo ciò che le dichiarazioni che si desidera eseguire, è possibile utilizzare la seguente sintassi (Scala):
var statement: PreparedStatement = session.prepare("INSERT INTO people (name,age) VALUES (?,?)")
var boundStatement = new BoundStatement(statement)
val batchStmt = new BatchStatement()
batchStmt.add(boundStatement.bind("User A", "10"))
batchStmt.add(boundStatement.bind("User B", "12"))
session.execute(batchStmt)
Nota: BatchStatement può contenere fino a 65536 istruzioni. Ho imparato questo nel modo più duro. :-)
PreparedStatement e valori di associazione potrebbero essere un'opzione migliore. Qui di seguito sono un paio di buoni articoli sugli usi e abusi di lotto:
Quale driver stai usando? Stai usando CQL? Quale versione di Cassandra? – Richard
La versione di Cassandra è 1.2.2x e sto usando hector apis. – ajjain