如何解决Cassandra查询只返回5000行
我使用此代码从cassandra查询数据，但结果只有5000行，但实际上数据库表中有12万行，我该如何查询所有数据？
from cassandra import ConsistencyLevel
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra.query import SimpleStatement
import pandas as pd
cluster = Cluster(contact_points=['192.168.2.4'],port=9042)
session = cluster.connect()
def testContectRemoteDatabase():
contact_points = ['192.168.2.4']
auth_provider = PlainTextAuthProvider(username='XXX',password='XX')
cluster = Cluster(contact_points=contact_points,auth_provider=auth_provider)
session = cluster.connect()
cql_str = 'select * from DB1.mytable ;'
simple_statement = SimpleStatement(cql_str,consistency_level=ConsistencyLevel.ONE)
execute_result = session.execute(simple_statement,timeout=None)
result = execute_result._current_rows
cluster.shutdown()
df = pd.DataFrame(result)
df.to_csv('./my_test.csv',index=False,mode='w',header=True)
if __name__ == '__main__':
testContectRemoteDatabase()
解决方法
这是by design：
默认情况下，
<Suspense>控制每页要提取多少行。可以通过在Session.default_fetch_size上设置fetch_size来覆盖每个查询。默认情况下，每个页面最多包含5000行。
将此设置为Statement将禁用自动分页：
None版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
