python - 在 cassandra 中处理分页结果

Question

我正在查看 this .但无法弄清楚它是如何工作的。我的期望是当我执行 session_execute 时，它会给我 10 行 fetch_size=10。

query = "SELECT * FROM users where region_code=1"
statement = SimpleStatement(query, fetch_size=10)
for user_row in session.execute(statement):
    print(user_row)
    print('*'*100)

它只给我单行。我在这里缺少什么。我想让它成为一个 paginated api

Answer 1

如果您使用 SELECT * FROM users where region_code=1 LIMIT 10 它将获取 10 条记录。如果您使用 SELECT * FROM users where region_code=1 获取大小为 10，它将分页浏览所有匹配的行，一次抓取 10 个。在您的 for 循环消耗 10 行后，它将进行另一个阻塞查询以自动获取接下来的 10 行。