我正在插入/更新多行/approximately 800行/到卡桑德拉表。我不想在python中使用循环。我搜索并找到了批处理查询。但不能用它。
请帮助我进行批处理查询或提供其他有效的方法,以插入多行卡桑德拉。
谢谢。
https://cqlengine.readthedocs.io/en/latest/topics/queryset.html#batch-queries
发布于 2022-03-02 05:48:15
CQL批处理不是一个优化--它们不会使您的查询运行得更快。事实上,如果有大批,则相反,因为它们会重载请求的协调器,而查询的运行速度也会变慢。
CQL批处理旨在实现原子性,因此(a)批处理中的所有语句都已成功执行,或(b)根本没有。
在Cassandra中,如果发出多个异步写入而不是单个批处理,则可以获得更高的吞吐量。更多的应用实例(客户端)表现得更好,因为单个客户端应用程序可能会阻碍流量。
如果您的目标是批量加载数据,我建议您使用像DataStax散装装载机 (DSBulk)这样的工具。DSBulk是一个免费的开源软件,允许您以CSV或JSON格式将数据批量加载到Cassandra集群。
以下是一些帮助您入门的资源:
https://stackoverflow.com/questions/71317767
复制相似问题