Cassandra单POST请求多插入操作的一致性保障及读写配置问题

同请求多插入的一致性保障 & Batch报错处理 #

• 现有单条独立插入的逻辑，完全没有跨语句的原子一致性保障。因为所有插入操作是独立通过协程发起的单条写请求，Cassandra本身不会对来自同一个客户端请求的多个独立写做顺序或原子性保障，很容易出现同一POST请求下部分行写入成功、部分行因为超时/节点故障写入失败的情况，后续GET请求自然可能读到残缺的、不一致的中间态数据。
• 你尝试用BATCH语句解决一致性问题时碰到的"Batch too large"报错，本质是Cassandra的硬限制触发的：Cassandra默认对单个提交的Batch有50KB（压缩前）的大小阈值，超过就直接拒绝服务抛错，和社区同类场景下的报错根因完全一致。
• 这里要纠正一个常见的认知误区：普通UNLOGGED BATCH本身没有任何跨操作的原子性，只是帮客户端减少和服务端的往返交互；只有LOGGED BATCH能提供跨语句的原子性，但一旦Batch内包含带IF NOT EXISTS这类条件判断的轻量级事务语句，哪怕没到大小阈值，也会因为需要额外协调所有副本的校验逻辑，触发超时甚至性能雪崩。很多人误以为Batch越大越高效，实际上Cassandra的Batch本身就是为小批量、跨分区的原子性场景设计的，大Batch的性能还不如单条顺序提交的写。
• 结合你当前的表结构，适配方案非常简单：你所有的插入操作分区键都是同一个id_1，所有行都落在同一个数据分区里，完全不需要用Batch做跨操作的协调。直接把同一次POST下的多个id_2的行，用单条插入语句的多组值语法提交即可，既绕开了Batch的大小限制，又因为同分区的写入在Cassandra内部是顺序落盘的，不会出现写一半的中间态。如果确实需要严格的逐行原子校验，注意控制单条Batch内的操作数在阈值内，且不要把不同分区的操作凑到同一个Batch里。

跨双数据中心的强一致配置方案 #

你的集群为2个数据中心、每个DC配置3副本，要实现端到端的完全一致性，需要按如下规则配置读写一致性级别：

• 写入端（对应POST请求）：需要将常规写的一致性级别设置为ALL。这个级别下，每次写入需要拿到两个DC内共6个副本节点的写确认，才算写入成功；如果你的写入用了带IF NOT EXISTS的轻量级事务，需要将串行一致性级别设置为SERIAL，匹配所有副本的校验要求，不能用LOCAL_SERIAL绕开跨DC的校验流程。
• 读取端（对应GET请求）：同样需要将读的一致性级别设置为ALL。这个级别下，每次读取会等两个DC内所有6个副本返回存储的行数据，基于最新时间戳做冲突合并后再返回给客户端，不会出现读到旧版本数据的情况。
• 实际落地的权衡提醒：全ALL级别的强一致配置会带来极高的跨DC网络延迟，且只要任意一个副本节点故障，对应分区的读写就会直接失败，集群可用性会大幅下降。如果业务请求本身是就近路由（同DC的请求打同DC的节点），可以根据业务容忍度调整为同DC的LOCAL_QUORUM级别读写，但这种配置下跨DC的请求会存在数据同步延迟，达不到真正的端到端完全一致。

内容的提问来源于stack exchange，提问作者overexchange