DataStax Enterprise 4.6.1 / Python 中的 C* 分页使用 cqlengine 0.21.0

DataStax Enterprise 4.6.1 / C* Pagination in Python using cqlengine 0.21.0

我目前正在尝试使用 Python 和 cqlengine 0.21.0 对来自 DSE 4.6.1 (Cassandra 2.0.12.200) 的查询结果进行分页。

我的table被查询是:

CREATE TABLE tags_for_search (
  village_id int,
  tag_prefix text,
  tag text,
  time timeuuid,
  author_id int,
  tag_id uuid,
  type text,
  PRIMARY KEY ((village_id, tag_prefix), tag, time)
) WITH CLUSTERING ORDER BY (time DESC) AND
  bloom_filter_fp_chance=0.010000 AND
  caching='KEYS_ONLY' AND
  comment='' AND
  dclocal_read_repair_chance=0.100000 AND
  gc_grace_seconds=864000 AND
  index_interval=128 AND
  read_repair_chance=0.000000 AND
  populate_io_cache_on_flush='false' AND
  default_time_to_live=0 AND
  speculative_retry='99.0PERCENTILE' AND
  memtable_flush_period_in_ms=0 AND
  compaction={'class': 'SizeTieredCompactionStrategy'} AND
  compression={'sstable_compression': 'LZ4Compressor'};

Python(使用 cqlengine 0.21.0)中的结果 paging/pagination(DataStax Enterprise / DSE 4.6.1)是否有替代方案?记录的解决方案 (http://cqlengine.readthedocs.org/en/latest/topics/queryset.html#token-function) appears to be broken due to #7016.

我对数据的初始查询是:

SELECT * FROM that_keyspace.tags_for_search WHERE "tag_prefix" = 'der' AND "tag_text" = '#derpy1' AND "village_id" = 1 LIMIT 10000;

或在 Python 中通过 cqlengine:

village_tags = VillageSearch.objects.filter(village_id=1, tag_prefix='der', tag_text='#derpy1')

tags_data = []
for village_tag in village_tags:
    tags_data.append(village_tag.to_dict())

first_page = village_tags
last = first_page[-1]
next_page = list(village_tags.filter(pk__token__gt=cqlengine.Token(last.pk)))

正在抛出错误:

code=2200 [Invalid query] message="Column "village_id" cannot be restricted by both an equality and an inequality relation"

是否有替代方法可以避免立即使用此错误?

感谢您提供的任何帮助!

此功能没有直接替代品。最好和最合适的答案是升级(现在这个错误修复可用)。

将您的环境升级到 DSE >= 4.6.2 将解决此问题。