如何使用cqlengine在cassandra中定义冻结列?

at0kjp5o  于 2021-06-14  发布在  Cassandra
关注(0)|答案(1)|浏览(365)

我试图在cassandra中创建一个冻结列表,这样我就可以使用该列作为主键,如果我手动运行查询,

some_field frozen <list<int>>

但我很难弄清楚如何在python中使用cqlengine,

some_field = columns.List(columns.Integer(), primary_key=True)

如何使用cqlengine完成相同的任务?
编辑:最后的代码片段如下所示,

from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model

class MyModel(Model):
    __table_name__ = 'my_table'
    __options__ = {'compaction': {'class': 'DateTieredCompactionStrategy',
                              'base_time_seconds': 3600,
                              'max_sstable_age_days': 1}}

    keys = columns.Set(columns.Integer(), primary_key=True)
    columns.BaseCollectionColumn._freeze_db_type(keys)
    time_stamp = columns.DateTime(primary_key=True, clustering_order="DESC")
    ...
xmq68pz9

xmq68pz91#

正如我在源代码中看到的,您需要调用函数 _freeze_db_type 在创建集合类型的示例后-此操作会将类型更改为 frozen<...> .

相关问题