我有一个应用程序，使用Akka沿着Cassandra进行事件源。作为API响应的一部分，我需要显示在特定时间范围内发生的特定类型/标签（例如UpdateEvent）的事件数量。是否存在任何接近的功能来实现这一点？我已经阅读了“eventsByTag”查询从查询插件，并从我所理解的提供一个事件流和使用它可以有巨大的影响，为客户端面对后端.纠正，如果我错了.我想我需要的是通过某种方式查询消息表来提取时间轴的事件，或者我应该使用流来填充一组新的读端表来实现功能。
u1ehiz5o1#
Cassandra（以及Akka Persistence Cassandra使用的模式）通常不适合这种查询，尤其是因为它将涉及扫描整个键空间，因此效率相当低。因此，理想的方法是将事件（例如使用Lagom的投影或Akka投影）到时间序列数据库中（这是CQRS的优点之一：使用最适合回答问题的查询模型的能力）。如果您没有现成的时间序列数据库，通过一些努力，您可以在更通用的数据库（如Cassandra或关系数据库）中实现该功能。
1条答案
按热度按时间u1ehiz5o1#
Cassandra（以及Akka Persistence Cassandra使用的模式）通常不适合这种查询，尤其是因为它将涉及扫描整个键空间，因此效率相当低。
因此，理想的方法是将事件（例如使用Lagom的投影或Akka投影）到时间序列数据库中（这是CQRS的优点之一：使用最适合回答问题的查询模型的能力）。如果您没有现成的时间序列数据库，通过一些努力，您可以在更通用的数据库（如Cassandra或关系数据库）中实现该功能。