我在 cassandra 中有这个架构：
create table if not exists
converstation_events(
timestamp timestamp,
sender_id bigint,
conversation_id bigint,
message_type varchar,
message text,
primary key ((conversation_id), sender_id, message_type, timestamp));
还有一个值为conversation_ended 的message_type，有没有办法对数据进行非规范化，以便我可以对那些已经结束的对话进行查询？
我考虑过有一个额外的字段，可以在会话结束消息到达系统时由触发器更新，这有意义吗？
【问题讨论】：
标签： cassandra data-modeling cqlsh
在 Cassandra 中，您需要以能够回答问题的方式对数据进行建模。它不像 RDBMS，您首先创建模型，然后创建查询。所以倒过来想想……
当您在 cassandra 中进行查询时（大多数情况下......），您需要通过主键进行查询，并且可以使用集群键来过滤或选择范围。 great post 就可以了。
您的converstation_events 表将为您提供有关对话的答案，按发件人、类型和时间进行过滤。 ** 如果要按时间过滤，则必须在查询中包含 sender_id 和 message_type。
但是您想要给定类型的所有对话，因此您需要另一个表来回答此查询。如果您想要conversation_ended 的所有对话，您可以创建第二个表来将消息类型映射到对话，例如 -
conversation_by_message_type (
message_type varchar,
conversation_id bigint,
timestamp timestamp,
primary key ((message_type), timestamp, conversation_id));
在客户端，只要您插入带有您可能想要查找的给定message_type 的convertation_events 事件，就必须向conversation_by_message_type 添加一条记录。我在此表中有timestamp，因此您可以按时间或time 和conversation_id 进行排序或过滤。
要查找所有已结束的对话，您可以执行以下查询
<ids> = select conversation_id from conversation_by_message_type where message_type = 'conversation_ended'
select * from conversation_events where conversation_id IN (<ids>)
【讨论】：