在cqlengine中插入多行
Insert multiple rows in cqlengine
我坚持 insert/update 多行/大约 800 行/到 cqlengine 的 cassandra table。我不想在 python 中使用循环。我搜索并找到了批量查询。但是不能用。
请帮助我进行批量查询或提供其他有效的方法来在 cassandra 中插入多行。
谢谢。
https://cqlengine.readthedocs.io/en/latest/topics/queryset.html#batch-queries
CQL 批处理不是优化——它们不会 使您的查询运行 更快。事实上,如果你有大批量,它们会做相反的事情,因为它们会使请求的协调器过载并且查询最终会变得更慢 运行。
CQL 批处理旨在实现原子性,因此 (a) 批处理中的所有语句都成功执行,或者 (b) none 根本没有执行。
在 Cassandra 中,如果发出多个异步写入而不是单个批处理,则可以获得更高的吞吐量。更多的应用程序实例(客户端)性能更好,因为单个客户端应用程序可能会造成流量瓶颈。
如果您的目标是批量加载数据,我建议您改用 DataStax Bulk Loader (DSBulk) 这样的工具。 DSBulk 是一款免费的 open-source 软件,允许您将 CSV 或 JSON 格式的数据批量加载到 Cassandra 集群。
这里有一些资源可以帮助您入门:
我坚持 insert/update 多行/大约 800 行/到 cqlengine 的 cassandra table。我不想在 python 中使用循环。我搜索并找到了批量查询。但是不能用。
请帮助我进行批量查询或提供其他有效的方法来在 cassandra 中插入多行。
谢谢。
https://cqlengine.readthedocs.io/en/latest/topics/queryset.html#batch-queries
CQL 批处理不是优化——它们不会 使您的查询运行 更快。事实上,如果你有大批量,它们会做相反的事情,因为它们会使请求的协调器过载并且查询最终会变得更慢 运行。
CQL 批处理旨在实现原子性,因此 (a) 批处理中的所有语句都成功执行,或者 (b) none 根本没有执行。
在 Cassandra 中,如果发出多个异步写入而不是单个批处理,则可以获得更高的吞吐量。更多的应用程序实例(客户端)性能更好,因为单个客户端应用程序可能会造成流量瓶颈。
如果您的目标是批量加载数据,我建议您改用 DataStax Bulk Loader (DSBulk) 这样的工具。 DSBulk 是一款免费的 open-source 软件,允许您将 CSV 或 JSON 格式的数据批量加载到 Cassandra 集群。
这里有一些资源可以帮助您入门: