用于重读/写的 cassandra 数据建模方法

Question

我是 cassandra 的新手，在以下场景的数据建模方面需要帮助。 在 oracle 中，我有两个类似于下面的表，我正在考虑迁移到 cassandra。

要解决的用例： 1. 繁重的读写。 2. 用户数据是先创建的，我们可以继续添加或删除帐户。 3.还将对其中一个用户帐户进行部分更新，例如更新帐户的金额或某些详细信息。 4. User_data 有一个字段来存储存在的活动 user_accounts 的计数。因此，每当我们在 user_account 表中添加或删除条目/行时。它将触发 user_data 中的更新。

基本上我不清楚如何为这些场景建模。是否只有一个表。但是有了这个，我不确定账户的数量 如果我有一个表并且将 user_accounts 作为 json 类型的列之一。然后，我相信我不能在那个 json 中进行部分更新。

考虑两个表的主要问题是事务管理。 如果我能够添加到 user_account，但无法更新 user_data，那么它将失败。

创建表 USER_DATA ( userId uuid 主键， 名称 varchar， noOfAccounts 整数，

..... #还有一些列...，

);

创建表 USER_ACCOUNTS ( 用户标识 uuid accountId uuid ,
整数， ..... #还有一些列...，

主键 (uuid,accountId) );

我尝试使用 FROZEN USER_ACCOUNTS 列表，但我们需要读取整个列表并在每次添加/删除或更新其中一个条目时回写。

我尝试使用json类型，但没有用。

Answer 1

在继续之前让我强调重点：您确定需要 NoSQL 和精确的 Cassandra 来存储用户和帐户吗？

Cassandra 专为大规模分布式数据而设计，并针对非常快速的写入进行了优化。如果您仍在考虑选择解决方案，我建议您花一些时间来调查现有解决方案，以及它们有效/无效的案例。网上有很多文章。例如。 https://www.infoworld.com/article/3268871/how-to-choose-the-right-type-of-database-for-your-enterprise.html

卡桑德拉。

选择结构前的重要问题：

• 用户添加新帐户和删除帐户的频率如何？
• 有多少用户同时进行该操作？
• 一般用户有多少个帐户？

强烈建议为您的所有用例编写性能测试，并在做出任何决定之前检查性能。

原始存储结构可以开始使用性能测试，但改进很少：

create table users.user_data (user_id uuid PRIMARY KEY, 
              name varchar, 
              account_count counter, 
              some_other_column varchar);

create table users.user_account (user_id uuid account_id uuid , amt int, 
PRIMARY KEY (user_id, account_id));

• users.user_data.account_count 字段的类型为counter
• 两者 表存储在keyspace 用户中。键空间配置对性能很重要。

如果我们为用户添加新帐户或删除现有帐户，我们应该进行影响多个表的事务。

也许最明显的事情是多分区批次，但那是慢。仔细阅读：Doc

建议尝试使用驱动程序代码进行异步写入。为您的编程语言选择 Cassandra DataStax 驱动程序。这是一个基于Java 代码的抽象示例来理解这个想法：

session.executeAsync("insert into users.user_account ...");
Futures.addCallback(future,
    new FutureCallback<ResultSet>() {
        @Override public void onSuccess(ResultSet result) {
            // Run query for incrementing counter in users.user_data table
        }
        @Override public void onFailure(Throwable t) {}
    },
    MoreExecutors.sameThreadExecutor() );

更新（2019 年 5 月 14 日）：

替代解决方案：单表和静态列看看https://blog.ippon.tech/modeling-data-with-cassandra-what-cql-hides-away-from-you/

看来静态列可以帮到你！

create table users.user_data (user_id uuid PRIMARY KEY, 
              name varchar static, 
              account_count counter static, 
              some_other_column varchar static,
              account_id uuid, 
              amt int, 
              PRIMARY KEY (user_id, account_id));

• 原来不属于 user_account 表的列被标记 作为静态
• 静态列仅在内部存储一次
• user_id 是分区键，account_id 是集群键。 Explanation

根据Is this type of counter table definition valid?，计数器列可以是静态的