Cassandra数据模型设计(上)

【编者注：InfoQ中文站得到了eBay工程师Jay Patel的受权，将会为陆续为读者呈现Cassandra数据模型设计的系列内容。】

本文是Cassandra数据模型设计第一篇（全两篇），该系列文章包含了eBay使用Cassandra数据模型设计的一些实践。其中一些最佳实践咱们是经过社区学到的，有些对咱们来讲也是新知识，还有一些仍然具备争议性，可能在要经过进一步的实践才能从中获益。

本文中，我将会讲解一些基本的实践以及一个详细的例子。即便你不了解Cassandra，也应该能理解下面大多数内容。

说说Cassandra在ebay的使用状况

咱们尝试使用Cassandra已经超过1年时间了。Cassandra如今正在服务一些用例，涉及到的业务从大量写操做的日志记录和跟踪，到一些混合工做。其中一项服务是咱们的“Social Signal”项目，支撑着ebay的pruduct pages里like/own/want特性。咱们开发的一些用例已经上线运行，但更多的仍是处于开发阶段。

咱们的Cassandra集群规模并不庞大，但正在稳步的增加中。在过去几个月里，咱们共部署了几十个节点，它们分布在几个跨机房的小型集群中。你可能会问，为何要多个集群？咱们经过的职能部门和业务来划分集群。相同职能部门的相同业务的用例共享一个集群，但它们存在于不一样的keyspaces中。

RedLaser, Hunch和其它ebay的合做伙伴也在尝试cassandra解决现实中各类问题。除了Cassandra，咱们也在使用MongoDB和Hbase，本文中我不会讨论它们，但我相信它们都有各自的优势。

我相信此时你必定有不少问题，在这篇文章里暂时不会一一说明。在即将到来的Cassandra Summit大会，我将更详细的讲解咱们每一个用例场景，数据模型和多数据中心部署，以及经验教训和其它知识。

本文重点讲述咱们在ebay应用的Cassandra数据模型设计最佳实践。下面让咱们先看看这系列文章会用到的一些术语。

术语和约定

• 术语“Column Name” 和 “Column Key”被认为是同样的。一样的，“Super Column Name” 和 “Super Column Key”也认为是相同的。

• 下图表示一个 Column Family (简称CF)中的一个row

• 下图表示一个 Super Column Family (简称SCF)中的一个row

• 下图表示一个Column Family中一个row，它包含Composite Columns。Composite Columns的属性经过分隔符’|’链接。请注意，这里看到的只是数据的表现形式，Cassandra内置了Composite Column，它是一个对象，并非使用’|’做为属性分隔符的字符串。（顺便说下，本文不要求你掌握Super Column和Composite Column方面知识。）

基于上面的内容，让咱们开始第一个实践吧！

不要把Cassandra model想象成关系型数据库table

取而代之，应该把它想象成事一个有序的map结构。

对于一个新手来讲，下面关系型数据库术语经常被对应到Cassandra模型

 

这种对比能够帮助咱们从关系型数据库转换到非关系型数据库。可是当设计Cassandra column famiy的时候请不要这样去类比。取而代之，考虑它是一个map中嵌入另外一个map：外部map的key为row key，内部map的key为column key，两个map的key都是有序的。以下：

SortedMap<RowKey, SortedMap<ColumnKey, ColumnValue>>

why？

将column family想象成嵌套的并排序的map比关系型数据库table描述的更为准确，它将帮助你正确的进行Cassandra模型设计。

How?

• Map能够进行高效查询，同时排序的特性能够进行高效column扫描。在Cassandra中，咱们可使用row key和column key作高效查找和范围扫描

• Column key的数量是很庞大的（译者注：目前译者所使用的Cassandra1.2.5版本，每一个row支持最多20亿个columns）。换句话说你，你能够拥有一个wide rows。

• Column key自身能够存储值，即你能够拥有一个没有值的column。

若是集群使用Order Preserving Partitioner (OOP)策略进行数据存储,就能够对row key进行范围查询。可是OOP大多数状况都不推荐使用（译者注：将rowkey按照顺序存储到节点上，若是分区不均匀，将致使数据读写不均衡），因此你能够认为外部的map是不排序的，以下：

Map<RowKey, SortedMap<ColumnKey, ColumnValue>>

上面提到的”Super Column”，认为它们是一组column，这样的话，两级嵌套map就会像下面展现的同样变为三级嵌套map：

Map<RowKey, SortedMap<SuperColumnKey,

           SortedMap<ColumnKey, ColumnValue>>>

注意：

• 你须要传递timestamp给每一个column value，由于Cassandra使用它作内部的冲突处理机制。但在建模过程当中你能够忽略它（译者注：在操做column的时候timestamp信息会自动添加到column）。同时，不要考虑在你的程序中使用column的timestamp，由于它不是为你设计的，与Hbase不一样，它们不会生成新的version数据（译者注：在Hbase中相同rowkey和column key的数据会保存多个version，而Cassandra会将相同数据覆盖，timestamp只保存最后一次更新的时间）。

• 由于Super Column的性能问题和缺少二级索引支持问题，Cassandra社区对它的使用曾有过强烈争议。因此，推荐使用Composite Columns代替Super Column实现功能。（译者注：使用Super Column，若是你要获取其中一个columnvalue，则要扫描整个Super Column,这会致使查询性能很糟糕）

围绕着查询模式进行Column Family建模

建模尽可能从实体和它们的关系开始

• 与关系型数据库不一样，在Cassandra中经过建立二级索引或者编写复杂SQL（使用joins, order by, group by）来新建或修改查询不是件容易的事情。由于Cassandra具备很高的分布式特性，因此要先考虑查询模式，而后再设计column family。

• 牢记前面提到的嵌入排序map数据结构，在考虑如何组织你的数据到map，以知足快速查询/排序/分组/过滤/聚合的要求。

在大部分状况下，实体和它们的关系是很重要的（特殊用例除外，如日志存储或者其它时间序列数据）。若是我给你一个查询模式，用于为一个电子商务网站建立Cassandra模型，但不告诉你任何实体和它们的关系。你会有意或者无心的从查询模式或者从你以前领域对象的理解找出实体和它们之间的关系（由于咱们是经过实体和关系来描述真实世界）。在设计数据模型时最好从实体和关系开始，而后使用反范式化和冗余的方式继续围绕查询模式建模。若是这听起来有些让人困惑，经过后面的详细例子就能够理解。

注意：在建模的时候考虑如下几点会颇有帮助。区分频次大的查询和频次小的查询，有些查询可能只被查询几千次，其它可能被查询数十亿次；还要考虑哪些查询对数据延迟是敏感的。确保你的模型优先知足查询频次大的查询和重要查询。

为提高读性能进行反范式化（De-normalize）和冗余

根据实际状况，若是不须要就不要反范式化。

在关系型数据库的世界里，范式化的优势是显而易见的：较少的数据冗余，较少的数据修改异常，概念更清晰，更容易维护等等；一样，它的缺点也十分明显：多表join查询会很慢等等。这两方面也会体如今Cassandra中，可是缺点会更明显，由于Cassandra数据是分布式存储，固然它也并不支持join操做。因此，对于一个彻底范式化的schema，Cassandra读操做性能可能比RDBMS更糟糕，因此咱们一般经过反范式化来提高查询性能。(译者注：Cassandra一次查询可能会请求多个节点并将结果汇总到客户端，而RDBMS查询只需从本地查询便可)。

这个实践和上一个查询建模实践是很是重要的，我会在余下的文章中经过一个详细的例子作进一步说明。

注意：下面咱们要讨论的例子只是个演示，它不表明eBayCassandra项目的数据模型。

实战：User和Item中间的’Like’关系

这个示例是关于电子商务系统的一个功能，一个user能够喜欢多个item，同时一个item能够被多个user所喜好，在关系型数据库中这个关系是经过many-to-many实现的，以下图所示：

经过上面的模型，咱们能够进行以下查询：

• 经过user id获取user

• 经过item id获取item

• 获取指定user喜欢的全部item

• 查看指定item被那些user所喜好

下面将介绍几个经过Cassandra建模解决上面问题的现方案，反范式的顺序从低到高。你会发现最佳方案依赖于查询模式。

方案1：彻底按照关系数据库模型设计

这个模型支持经过user id查询user和经过item id查询item。但没法简单查询某个user喜好的全部item或者某个item被那些user所喜好。

对于这个用例来讲，这是最糟糕的设计，主要是由于User_Item_Like没有设计好。

注意：为了简单起见，关系型数据模型中的timestamp字段没有体现到Cassandra模型中（这个字段用于存储user什么时候喜好某个item），我会在后面介绍它。

方案2：使用自定义索引范式化实体

这个模型中User和Item是范式化实体，user id 和item id被映射存储两次，第一次是经过item id存储user id（User_By_Item），第二次经过item id存储user id（Item_By_User）。

这样，咱们很容易能够经过Item_By_User查询某个user喜欢的所有item，还能够经过User_By_Item查询某个item被哪些user所喜好。这里咱们使用了，Item_By_User和User_By_Item这两个column family做为自定义二级索引。（译者注：Cassandra column family也有二级索引功能，它的做用是经过建立column key索引快速查询到column value）。

有这样一个场景，咱们老是但愿经过指定user查询其喜好的item，同时要获取item title信息。在当前模型下，咱们首先要经过Item_By_User获取指定user关联的item id，而后根据这些item id依次查询Item模型获取title信息，反之亦然。一个item有可能被几百个user所喜好，或者一个活跃user可能喜好许多item，基于当前的模型设计，将会致使不少额外的查询。因此，最好经过反范式‘Item_by_User’ 中的itemtitle和’ User_by_Item’中的username信息来优化查询，方案3将会向你们展现。

注意：即便你能够批量读取（译者注：在Cassandra Java客户端hector中能够MultigetSliceQuery类实现一次查询传入多个rowkey），但它们将仍然很慢，由于Cassandra底层仍然会单独查询每一个rowkey，而后经过Coordinator 节点（译者注：Coordinator 节点为Cassandra客户端直接请求的节点，能够理解为它是一个代理）汇总到客户端。批量读取能够避免请求的往返耗时，它是个不错的选择，你能够去尝试它。

方案三：范式化实体，并将它们反范式化到自定义索引

在这个模型中，title和username被分别反范式到User_By_Item和Item_By_User。这样将容许咱们高效查询指定user喜好的全部item，以及喜好指定item全部的user。这样咱们就为整个用例作了很大的反范式化工做。

问题又来了，如何获取指定user喜好item的具体信息（title,desc,price等等）？首先咱们要问问本身咱们是否真的须要这个查询。仍是上面的例子，当用户但愿获取item额外信息的时候，咱们能够在页面上展现全部的item title，当点击item title时，在打开的新页面显示这个item的具体信息。因此，在这个用例中咱们最好不要极端反范式化。（item title列表中一般还会显示title和price信息，这也很容易实现，这个就留给你们作练习）

让咱们考虑下面两个查询：

• 经过所给item id，获取具体item信息（title, desc等等），并一同查询喜欢这个item的user name

• 经过所给的user id，获取具体user信息，并一同查询user喜欢的全部item titile

上面两个查询出如今查询item和user的详情页面是很正常的，这些在当前模型中能够很好的实现。二者都须要两次查询，一次查询item（或者user）信息，另外一次查询user name（或者item title）。User变得更加活跃的（喜欢上千个items）或者item变得很热门（被几百万user喜好），查询的次数不会随之增长，仍然为两次。这很好，当咱们从方案2到方案3，反范式化并无让咱们变糟糕。让咱们看看方案4如何作更进一步的优化。

 

方案4：范式化部分实体

很明显，方案4看起来有些凌乱。在数据存储结构上，它与方案3也不一样。

若是User和Item之间是高度关联的实体（相似ebay），相比当前方案我将更倾向于方案3。

由于咱们不打算反范式化全部item属性到User实体或者反范式化全部user属性到Item实体，因此这里咱们使用了部分范式化。我不会打算进行极限反范式化（让全部time属性到User实体和全部user属性到Item实体），由于在这个用例中那样作是没有意义的。

注意：这里我使用Super Column只是为了给展现。大多状况，应该倾向于使用composite columns，而不是Super Column。

最佳模型

在本文的用例中方案3是优胜者。上面的方案中咱们忽略了timestamp信息，下面咱们将把它以timeuuid(type-1 uuid)形式添加到最终模型上。注意，在User_By_Item实体中timeuuid和userid合并为一个composite column key，在Item_By_user实体中timeuuid和item id合并为一个composite column key。

回想一下，column key是有序存储的。这里咱们的User_By_Item 和 Item_By_User两个实体的column keys经过timeuid排序后被存储到磁盘，这使得基于时间的范围查询很是高效。在这个模型中，咱们不须要读取一个row中全部column，就能够高效的查询某个item最近被哪些user所喜好，以及某个用户最近喜欢了哪些item。

最终模型以下：

总结

咱们经过一些基本的实践和详细例子帮你开启Cassandra数据建模之旅。下面是一些关键点：

• 当设计Cassandra列族时，不要把它想成是关系表，要把它想成是嵌套的、排序的map数据结构。

• 要围绕着查询来设计列族，从设计实体及其关系开始。

• 在须要的时候，经过反范式化和冗余来提高读性能。

• 记住有多种方式建立模型，最佳的方式依赖于你的用例和查询模式。

这里我没有提到其它经常使用的用例，如日志记录、监控、实时分析（rollups, counters），或者时间序列。可是，咱们讨论的实践也适用于它们。此外，有些众所周知的技术和模式用于时间序列的模型设计。在eBay，咱们也使用这些技术，也乐于在后续的文章中分享这些。关于时间序列数据建模，我推荐你阅读 Advanced time series with Cassandra 和 Metric collection and storage，若是你是Cassandra新手，请先阅读DataStax documentation。

原文连接：http://www.ebaytechblog.com/2012/07/16/cassandra-data-modeling-best-practices-part-1/