Cassandra: Список последних покрытий для пользователя

Question

Мы используем cassandra для хранения данных чата. мы должны поддерживать все разговоры пользователей и сортировать их на основе полученных сообщений.

Разговор: Является потоком сообщений от 2 или более пользователей. Беседы не имеют конечного времени и непрерывны.

Мы поддерживаем таблицу, в которой есть «пользователь для разговоров» на основе времени создания беседы. Но мы хотели бы отсортировать его на основе полученных сообщений.

Solutions

• Решение -1:

Я смотрел на аналогичный вопрос Cassandra: List 10 most recently modified records

, который предлагает использовать материализованное представление. Этот подход подходит для часто обновляемых записей, таких как сообщения.

• Решение -2: Используйте другую таблицу, чтобы поддерживать пользовательские вызовы в списке. Обновите список, когда сообщения будут отправлены/отправлены пользователю.

Учитывая вопрос об использовании, пожалуйста, предложите, что было бы лучшим решением.

Answer 1

На самом деле вы хотите отсортировать все сообщения по всему миру. Действительно, сортировка разговоров по самому последнему сообщению означает сортировку всех сообщений.

Простой способ решить проблему заключается в создании еще одну таблицу, где вы храните каждое полученное сообщение с целью упорядочения беседы:

CREATE TABLE conversations_by_most_recent_message (
    conversation_id int, 
    ts timestamp, 
    message text, 
    PRIMARY KEY (conversation_id, ts) 
) WITH CLUSTERING ORDER BY (ts DESC); 

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

Второй шаг, который нужно сделать, это получить самую последнюю запись из каждого раздела, и это может быть легко решена эксплуатируя пункт PER PARTITION LIMIT введенный в Кассандре 3.6:

SELECT * FROM conversations_by_most_recent_message PER PARTITION LIMIT 1; 

Это закачает только первая запись из каждого раздела, то есть только самое последнее сообщение из каждого разговора.

Последний шаг - сортировать (по timestamp desc) строки, полученные на уровне приложения.