Блокировка взаимного исключения Cassandra (синхронизация)

Question

Есть ли способ синхронизации клиента с использованием встроенных функций cassandra?

Мне нужно выполнить некоторые операции, и эти операции должны быть синхронизированы со всеми другими клиентами (взаимное исключение).СУБД Я могу заблокировать всю таблицу или подготовить специальную таблицу для целей синхронизации и использовать для нее SELECT ... FOR UPDATE.

Можно ли добиться этого с помощью Cassandra без каких-либо сторонних приложений?Если нет, то какой лучший способ сделать это?Предпочтительными языками являются Java и Python.

Answer 1

Невозможно заблокировать весь (или подмножество) семейства столбцов без сторонних библиотек, таких как Apache ZooKeeper .

Вероятно, я бы начал смотреть на Domic Williams cage , прежде чем начать свой собственный механизм распределенной блокировки

Answer 2

Поскольку C * обеспечивает атомарность на уровне строк, почему бы не использовать Алгоритм хлебопечения Лампорта .Я нашел неполную страницу и на C * wiki.

https://github.com/jakedouglas/cassandra_lock

Answer 3

Если вы обновляете одну строку в семействе столбцов, она является атомарной. Но это не будет работать, как выбрать для обновления. Вероятно, вам следует пересмотреть свою модель данных с учетом большей денормализации, чтобы вам не пришлось беспокоиться о синхронизации.

Answer 4

Я также искал способ сделать синхронизацию с кассандрой, но, насколько я знаю, она не предоставляет механизмов для реализации мьютексов.

Однако в memcached есть атомарная операция cas (проверить и установить), которую можно использовать для реализации мьютекса. Он также имеет клиентов Python и Java.

Таким образом, вы можете использовать memcached для реализации мьютексов для синхронизации и выполнять чтение / запись данных с уровнем согласованности кворума в cassandra, чтобы убедиться, что последняя запись всегда возвращается при чтении.

У кого-нибудь есть опыт реализации мьютекса с memcached?