Cassandra批量查询与单次插入性能
我使用卡桑德拉爪哇驱动程序。
我每秒接收15万个请求，并将其插入到具有不同分区键的8个表中。
我的问题是哪种方式更好：
- 批量插入这些表
- 一个接一个地插入。
我问这个问题是因为，考虑到我的请求大小(150k)，批处理听起来是更好的选择，但是因为所有的表都有不同的分区键，所以批处理显得很昂贵。
共有2个答案
批处理反而会对性能产生巨大影响。根据我的理解，最适合您的解决方案是将每个分区键拆分为不同的列表，然后使用批处理语句。您将看到对性能的巨大影响。
请从下面的链接查看我的答案:
具有不同分区键的表上的Cassandra批处理查询性能
批处理不是为了提高性能。它们用于确保原子性和隔离性。
批处理对于单个分区写操作可能是有效的。但是批处理经常被错误地用来优化性能。根据批处理操作，性能实际上可能会恶化。
https://docs.datastax.com/en/cql/3.3/cql/cql_using/useBatch.html
如果这些表之间不需要数据一致性，则使用单插入。单个请求在节点之间正确分发或传播（取决于负载平衡策略）。如果您担心请求处理和使用批处理，批处理将在协调器节点上负担如此多的额外工作，这将不会有效，我想:)
-
我是卡桑德拉的新人。我必须使用c#在卡桑德拉中一次性插入50000行。我正在使用卡桑德拉c#驱动程序。我正在使用以下代码在卡桑德拉中插入数据。请帮帮我 我收到错误：批处理中的语句无效：只允许UPDATE、INSERT和DELETE语句。
-
在Cassandra中，用于同时执行多个修改语句(插入，更新，删除)。 当你必须更新一些以及删除一些现有的列是非常有用的。 语法 实例： 让我们举个例子来演示命令。 在这里，我们有一个名为“”的表，其中包含列(，，)，具有以下数据。 在这个例子中，我们将执行BATCH(插入，更新和删除)操作： 插入一个包含以下信息的新行(，，)。 更新行ID为的学生的列的值为。 删除具有行ID为的雇员的值。 完整
-
我已经创建了一个密钥空间。 我只有两个节点，DC1和数据中心1节点都已启动。现在，当我试图执行一批insert语句时 我收到一个例外，说 当我移除.ifNotExists（）子句时，批处理执行没有任何异常。 使用数据轴驱动程序版本 2.1.7 。 我应该如何解决这个问题？ 编辑:节点工具状态
-
我正在写一个数据挖掘程序，可以批量插入用户数据。 当前SQL只是一个普通的批量插入： 如果发生冲突，如何进行更新？我试过： 但它抛出
-
1） 有没有办法记录在Cassandra中执行的查询 2）为了提高性能，我了解cqlsh中的TracingON是一个很好的功能，用于跟踪我们在cqlsh中执行的单个查询。但是是否有一种方法来分析Cassandra查询，它给出了执行时间、查询数据大小等。，
-
问题内容： 这是我在阅读有关jpa批量插入的几个主题之后创建的简单示例，我有2个持久对象User和Site。一个用户可以拥有多个站点，因此我们在这里有一对多的关系。假设我要创建用户并将多个站点创建/链接到用户帐户。考虑到我愿意为Site对象使用批量插入，代码如下所示。 但是，当我运行此代码时（我将hibernate方式用作jpa实现提供程序），我看到以下sql输出： 所以，我的意思是“真实的”批量