Wie zu vermeiden Daten überschreiben (verloren) schreiben - Update auf das gleiche Objekt von mehreren Thread in Cassandra

Question

Ich bin ein mehrere thread zu tun, um Änderungen und Updates auf dem gleichen Objekt zu tun!

wir halten es einfach:

Ich habe ein obj1: | ID | Zähler | Zeitstempel | :)

run() 3 Thema T1, T2 T3 Zähler zu tun ++

Ich bin neu in Cassandra so aus Ihrer Erfahrung, wie kann ich sperren das Objekt meiner aktualisieren oder Hexe-Lösung zu tun, du für mich vorschlagen zu verwenden, um das Überschreiben der Daten in einer solchen Situation zu vermeiden!

suchen, von Ihnen zu hören und danken Ihnen

Answer 1

Es gibt keine Schlösser. Anstatt dasselbe Objekt zu mutieren, schreiben Sie ein Protokoll der Mutationen, die Sie abstimmen sollten. Suchen Sie nach CRDT oder Event Sourcing und je nach Szenario können Dinge ein wenig anders umgesetzt werden.

Alternativ können Sie Transaktionen mit geringem Gewicht verwenden und so lange versuchen, bis Ihre Mutation funktioniert, aber Ihr Durchsatz wird im Vergleich sehr gering sein. Je nach Ihren Gleichzeitigkeit/Durchsatzanforderungen kann es ausreichen, wenn

UPDATE purchases SET balance=-200 WHERE user='user1' IF balance=-208; 

Wenn es mit neuen Wiederholung schlägt fehl, wenn/Balance-Klausel.

Erwähnenswert gibt es einen Zählertyp: https://docs.datastax.com/en/cql/3.1/cql/cql_using/use_counter_t.html , wenn Ihr gerade oder Dekrementieren Inkrementieren, die Ihren speziellen Fall tun würde.