Python Cassandra Paging

cassandra_paging.py

from cassandra.cluster import Cluster
from cassandra.query import SimpleStatement


cluster = Cluster(['taojy123.com'])
session = cluster.connect('taiqiyun')

query = "SELECT * FROM best" 

statement = SimpleStatement(query, fetch_size=2)
ps = None

print('------1')
page1 = session.execute(statement, paging_state=ps)
ps = page1.paging_state
for row in page1.current_rows:
    print(row)


print('------2')
page2 = session.execute(statement, paging_state=ps)
ps = page2.paging_state
for row in page2.current_rows:
    print(row)


print('------3')
page3 = session.execute(statement, paging_state=ps)
ps = page3.paging_state
for row in page3.current_rows:
    print(row)