如何在 Cassandra 中将批处理语句和 LWT 作为事务执行

我有两个模型如下的表：

CREATE TABLE IF NOT EXISTS INV (
  CODE TEXT,
  PRODUCT_CODE TEXT,
  LOCATION_NUMBER TEXT,
  QUANTITY DECIMAL,
  CHECK_INDICATOR BOOLEAN,
  VERSION BIGINT,
PRIMARY KEY ((LOCATION_NUMBER, PRODUCT_CODE)));

CREATE TABLE IF NOT EXISTS LOOK_INV (
  LOCATION_NUMBER TEXT,
  CHECK_INDICATOR BOOLEAN,
  PRODUCT_CODE TEXT,
  CHECK_INDICATOR_DDTM TIMESTAMP,
PRIMARY KEY ((LOCATION_NUMBER), CHECK_INDICATOR, PRODUCT_CODE))
WITH CLUSTERING ORDER BY (CHECK_INDICATOR ASC, PRODUCT_CODE ASC);

我有一个业务操作，需要更新表中的 CHECK_INDICATOR 和 INV 表中的 QUANTITY。 由于 CHECK_INDICATOR 是 LOOK_INV 表中键的一部分，我需要先删除该行并插入新行。 以下是我需要以批处理方式执行的三个操作（要么全部成功执行，要么不执行）

1. 从 LOOK_INV 表中删除行。
2. 在 LOOK_INV 表中插入行。
3. 更新 INV 表中的 QUANTITY 和 CHECK_INDICATOR。

由于 INV 表正在被多个线程访问，因此我需要在更新 INV 表行之前确保它自上次读取以来尚未更改。 我正在使用 LWT 事务来更新 INV 表，使用 VERSON 列和批量操作在 LOOK_INV 表中进行删除和插入。我想批量添加所有三个操作。但是由于 LWT 在批量中不可接受，因此我需要以上述方式执行。

这种方法的问题是，在某些情况下批处理成功执行，但更新 INV 表会导致超时异常，并且两个表中的数据变得不一致。

cassandra是否提供了任何功能来优雅地处理此类场景？

小心轻量级事务 (LWT)

由于您遇到的性能问题，轻量级事务目前被认为是 Cassandra 反模式。

这里有一些上下文需要解释。

Cassandra 不使用具有回滚或锁定机制的 RDBMS ACID 事务。它不提供锁定，因为对各种分布式数据存储的基本约束称为CAP定理 https://en.wikipedia.org/wiki/CAP_theorem。它指出分布式计算机系统不可能同时提供以下所有三个保证：

• 一致性（所有节点同时看到相同的数据）
• 可用性（保证每个请求都会收到有关成功还是失败的响应）
• 分区容错性（尽管任意消息丢失或系统部分故障，系统仍继续运行）

因此，Cassandra 不适合原子操作，您不应该将 Cassandra 用于此目的。

它确实提供了轻量级事务，在某些情况下可以代替锁定。但由于 Paxos 协议（LWT 的基础）涉及节点之间发生的一系列操作，因此在提出 LWT 的节点和属于事务一部分的其他副本之间将存在多次往返。

这会对性能产生不利影响，并且是 WriteTimeoutException 错误的原因之一。在这种情况下，您无法知道是否已应用 LWT 操作，因此您需要重试以回退到稳定状态。由于 LWT 非常昂贵，驱动程序不会自动为您重试。

如果频繁使用，LTW 会带来很大的性能损失，并且我们看到一些客户端由于使用 LWT 而出现严重的超时问题。

轻量级事务通常是一个坏主意，不应该经常使用。

如果您的部分工作负载确实需要 ACID 属性，但仍需要扩展，请考虑将这部分负载转移到蟑螂BD https://blog.pythian.com/datascape-episode-28-getting-know-cockroachdb-fernando-ipar/。 总之，如果您确实需要 ACID 事务，那么引入第二种技术通常会容易得多。