卡桑德拉 - 批次太大

Question

我有一个必须添加到采购订单的产品列表。采购订单具有序列号，添加产品后，应更改其状态以指示这些产品已出货。

1 个采购订单中处理的典型产品数为 500。

在DB上-我有2张桌子-

各方面的建议告诉我应该使用多个异步查询。然而，我关心的是整个操作的原子性。鉴于我的要求，请建议什么是最好的前进方式。

先谢谢你。

Answer 1

然而，我担心的是整个操作的原子性。鉴于我的要求，请建议什么是最好的前进方向。

请注意，Cassandra批次不提供隔离（http://www.datastax.com/dev/blog/atomic-batches-in-cassandra-1-2）：

请注意，我们在数据库意义上的意思是“原子”，即如果批处理的任何部分成功，那么所有部分都会成功。未暗示其他担保；特别是没有隔离；其他客户端将能够从批处理中读取第一个更新的行，而其他客户端正在进行中。

因此，如果您需要隔离，正如@xmas79回答的那样，您应该将产品和采购订单一起存储在一个表中。

如果隔离和性能不重要，可以尝试调整Cassandra yaml并增加batch_size_fail_threshold_in_kb参数的值

任何超过此值的批次都将失败。默认为50kb (10x警告阈值)。

Answer 2

这很有趣。插入大量插入物（

因为Cassandra也在单行级别管理原子性，所以您可以通过添加一个表来“标记”您的采购订单，在一行中只将采购订单id和商品存储到一个映射中，从而在您的查询中实现幂等性。然后，您可以展开或后期处理此表，以根据需要继续您的工作流程。