批量删除datastax c#

Question

我对 Cassandra 数据库很陌生。我有一个关于使用 cassandra 的问题。

表结构如下：-

表名称：- 产品详细信息。

ProductFamily 文本，

访问组文本，

产品详情图

((ProductFamily), AccessGroup) 主键

数据关系：-

对于 1 个产品系列，我们有多个访问组，每个访问组在 Map 中都有产品详细信息。很可能 1 个产品详细信息存在于所有访问组或某些访问组中。

场景 1：-

1. 我们收到一个仅包含 ProductId 和产品系列的删除事件。

我们的实现：-

1. 从数据库中获取产品系列的所有访问组。

2. 对于每个访问组，点击数据库获取地图，然后我们检查它是否有特定的productid作为地图键。

3. 如果是，则将该 accessgroup -> productid (key,value) 对保存在内存中。

4. 最后，准备批处理语句删除访问组的所有产品id，因为我们的分区键相同。

注意 - 最大。我们在一个地图中有 15-20 个项目和一个产品系列的 8-10 个访问组。

.

问题：-

1. 能否告诉我我是否遵循了正确的批量删除方法？

2. 如果我们在一天内收到数千个此类事件，这种方法是否有效？

提前致谢。

Answer 1

一般来说，如果目标是提高性能，我们不建议使用批处理。但是，当批处理中的所有语句都引用相同的分区键（相对于发送单独的异步请求）时，一些用户报告了性能改进，因此您的方法实际上可能是提供最佳性能的方法。

可能会损害性能的一件事是这种方法的“尖峰”性质。 Cassandra 节点做这样的事情可能会更好：

1. 从数据库中获取产品系列的所有访问组。

2. 对于每个访问组，点击数据库获取地图，然后我们 检查它是否有特定的 productid 作为映射键。

3. 如果是，则异步发送 DELETE 请求并将Task 保存在内存中（无需立即等待）。

4. 最后，等待所有保存在内存中的任务，await Task.WhenAll(tasks)。

虽然不能保证这种方法会更好，但性能测试和基准测试是确定这一点的唯一方法。