如何使用 cqlengine 在 Cassandra 中定义冻结列?
How to define frozen columns in Cassandra using cqlengine?
我正在尝试在 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")
...
作为 I see in the source code,您需要在创建集合类型的实例后调用函数 _freeze_db_type
- 这会将类型更改为 frozen<...>
。
我正在尝试在 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")
...
作为 I see in the source code,您需要在创建集合类型的实例后调用函数 _freeze_db_type
- 这会将类型更改为 frozen<...>
。