0

我在 python 中创建

from uuid import uuid4
from uuid import uuid1

from cassandra.cqlengine import columns, connection
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.management import sync_table


class BaseModel(Model):
    __abstract__ = True

    deleted = columns.Boolean(required=True, default=False)
    created_timestamp = columns.TimeUUID(primary_key=True,
                                         clustering_order='DESC',
                                         default=uuid1)

class OtherModel(BaseModel):
    __table_name__ = 'other_table'
    id = columns.UUID(primary_key=True, default=uuid4)



if __name__ == '__main__':
    connection.setup(hosts=['localhost'],
                     default_keyspace='test')
    sync_table(OtherModel)

这给出了错误

python /tmp/test.py
Traceback (most recent call last):
  File "/tmp/test.py", line 9, in <module>
    class BaseModel(Model):
  File "/usr/lib/python2.7/site-packages/cassandra/cqlengine/models.py", line 905, in __new__
    raise ModelException("clustering_order may be specified only for clustering primary keys")
cassandra.cqlengine.models.ModelException: clustering_order may be specified only for clustering primary keys

如果我发表评论，clusturing_order那么它的工作正常。

class BaseModel(Model):
    __abstract__ = True

    deleted = columns.Boolean(required=True, default=False)
    created_timestamp = columns.TimeUUID(primary_key=True,
    #                                    clustering_order='DESC',
                                         default=uuid1)

有什么方法可以clusting_order在abstract类中定义吗？

我必须created_timestamp在每个模型中创建，所以我不能将它移动到每个模型。

4

1 回答 1

2

Cassandra 中的主键有两个组件：分区键和集群键。分区键确定该行将存储在集群中的哪个节点上。群集键确定该分区键中行的磁盘排序顺序。

同样重要的是要注意，但不能订购分区键。多分区键结果始终按其哈希令牌值的顺序返回。

看起来您的基本模型只有一列 ( created_timestamp) 定义为键，因此那是您的分区键。我没有看到另一个键被定义，所以你没有集群键，因此你不能应用clustering_order.

在 Cassandra 中，您需要根据您打算提供的查询来定义您的表。如果没有看到您的查询，很难告诉您如何解决这个问题。但本质上，您需要使用不同的分区键并指定created_timestamp为集群键才能获得所需的结果。

有关更多信息，您应该在此处阅读 Carlo 的回答：

Cassandra中分区键，复合键和集群键之间的区别？

于 2016-12-23T15:49:31.507 回答