每个 POST 请求执行多次插入

Question

我们有一个场景，每个插入id_2在Cassandra中给定id_1，对于下面的架构：

CREATE      TABLE  IF    NOT    EXISTS my_table (
  id_1                   UUID,
  id_2                   UUID,
  textDetails            TEXT,
  PRIMARY KEY (id_1, id_2)
);

单个 POST 请求正文包含id_2多个值的详细信息。这将触发单个表上每个 POST 请求的多个插入。

每个INSERT查询如下所示执行：

insertQueryString = "INSERT INTO my_table (id_1, id_2, textDetails) " + "VALUES (?, ?, ?) IF NOT EXISTS"
    cassandra.Session.Query(insertQueryString, 
    id1,                            
    id2,        
    myTextDetails).Exec();

1个

Cassandra是否确保每个POST请求在单个表上的多个插入上的数据展示一致性？每个POST请求都在Go例程（线程）上处理。后续GET请求应确保检索一致的数据（通过POST插入）

使用批处理语句在暂存时会出现“批处理太大”的问题

2个

我们有两个数据中心（用于Cassandra），每个数据中心有3个副本节点。

为确保完全一致性，需要为写查询操作(POST请求)和就绪查询操作(GET请求)设置什么样的一致性级别

Answer 1

这里有多个问题:

• 在Cassandra中应该非常小心地使用批处理-仅当您将数据插入同一个分区时。如果您将数据插入多个分区，那么最好使用并行执行的单独查询（但您可以收集每个分区键的多个条目并对其进行批处理）。
• 您正在使用IF Not EXISTS，它是针对同一个分区完成的——结果它会导致多个节点之间的冲突（参见轻量级事务的留档），并且它需要从磁盘读取数据，因此它会大大增加节点的负载。但是您真的需要仅在行不存在时才插入数据吗？如果行已经存在，问题是什么？在执行INSERT时，只需覆盖Cassandra中的数据就更容易了，因为它不需要从磁盘读取数据。

关于一致性级别——QUORUM（或LWT的SERIAL）将为您提供强大的一致性，但代价是延迟增加（因为您需要等待另一个DC的回答）和缺乏容错能力——如果您丢失另一个DC，那么您的所有查询都将失败。在大多数情况下，LOCAL_QUORUM就足够了（LOCAL_SERIALLWT的情况下），它将提供容错能力。我建议阅读这份关于在Cassandra之上构建容错应用程序的最佳实践的白皮书。