Обновления в cassandra

Question

Cassandra data modeling respects «Денормализация и дублирование данных - это факт жизни с Кассандрой». Но один из недостатков демармализованных данных делает обновления очень сложными. Например, если у меня есть три стола, обслуживающих разные запросы, выбор в порядке. Однако, если в моем приложении я хочу обновить имя пользователя, и мне нужно обновить эти три таблицы? Обновление в первой таблице выглядит нормально. Как насчет последних двух? Исходы будут очень дорогими? Как я должен обрабатывать этот случай?

CREATE TABLE users_by_username (
    username text PRIMARY KEY, 
    email text, 
    age int 
) 

CREATE TABLE users_by_email (
    email text PRIMARY KEY, 
    username text, 
    age int 
) 

CREATE TABLE groups (
    groupname text, 
    username text, 
    email text, 
    age int, 
    hash_prefix int, 
    PRIMARY KEY ((groupname, hash_prefix), username) 
) 

Answer 1

Это типичная проблема, которую я вижу, когда люди пытаются поставить реляционную модель в Кассандре, которая обновляется во времени. Cassandra - отличная база данных и для чего она работает, она творит чудеса. Существует множество функций, которые позволяют использовать всевозможные модели данных, и вы можете охватить практически все варианты использования. Когда вы смотрите на свой случай использования, возникает вопрос, почему вы использовали Cassandra для реляционной модели? Если вы действительно хотите, чтобы Cassandra закрывал ваш прецедент, вам нужно будет выполнить множество различных операций на уровне приложений, чтобы выполнять обновления и поддерживать ваши данные в согласованном состоянии.

Answer 2

После просмотра нескольких клипов на YouTube, похоже, что обновление Canssandra - это простая запись, чтобы добавить запись в журнал фиксации в файловой системе. Затем данные помещаются в memtable на сервере cassandra и сразу же отправляют подтверждение клиенту. Таким образом, вызов для обновления завершается. Это ускоряет обновление клиентов.

После этого весь процесс уплотнения происходит, включая промывку, последовательную запись и слияние на основе метки времени.