Cassandra：为用户列出最近的Coversing

Question

会话：是2个或多个用户之间的消息流。对话没有结束时间，并且是连续的。

我们正在维护一个表，该表基于会话创建时间具有“用户到会话”。但我们希望根据收到的消息对其进行排序。

解决方案

null

null

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);

每当消息到达时，您将其存储在那里。在这个表中，您将有与每个会话相关的所有消息，这些消息按时间顺序颠倒排列。从该表中获取数据将帮助您了解每次会话的最后一条消息的时间戳。

SELECT * FROM conversations_by_most_recent_message PER PARTITION LIMIT 1;