当前位置: 首页 > 知识库问答 >
问题:

卡桑德拉不一致

秦阳旭
2023-03-14

我们运行的cassandra集群有3个节点,复制因子为2。

我们的nodejs服务器是查询这个集群的唯一地方。

var client = new cassandra.Client({contactPoints: [<contact point>], keyspace: 'test_keyspace', queryOptions: {consistency: cassandra.types.consistencies.two}});

是否有其他任何地方的参数设置可能导致不一致的查询?

cassandra v2.2.4 nodejs驱动程序v3.0.0

编辑-添加我正在做的事情的示例:

1)检查用户名是否被占用

        var query = "SELECT * FROM test_keyspace.username WHERE username=?";
        db.execute(query, [username], function(err, result){
            if(err){
                //fail check - api responds with internal server error
            } else {
                if(result.rows.length == 0){
                //pass check, proceeed to #2
                } else {
                //fail check, username taken, respond with error
                }
            }
        });

2)创建用户

var queries = [
    {
        query: "INSERT INTO test_keyspace.users (id, username, join_date) VALUES(?, ?, ?)",
        params: [userid, username, date]
    },
    {
        query: "INSERT INTO test_keyspace.username(id, username) VALUES(?, ?)",
        params: [userid, username]
    }
]

db.batch(queries, {prepare: true}, function(err){
    if(err){
        //api responds here with error
    } else {
        //api responds here with success
    }
});

共有1个答案

孟彦
2023-03-14

问题是我的cassandra服务器上的时钟没有同步。

 类似资料:
  • 我使用的是spring数据cassandra,需要使用jpa映射一个字段,在cassandra中,该字段的类型为

  • 我们一直在使用Spark RDD API(Spark 2.0)来处理在Cassandra.Note中建模的数据,这些数据在Cassandra中建模以实现高效的读写。 然而,现在还有SparkSQLAPI,Spark DataFrame API,它也是一种替代的数据访问方法-http://spark.apache.org/docs/latest/sql-programming-guide.html

  • 我用Spring Data Cassandra 2.2.1开发了一个新的应用程序,想在Cassandra 2.1.9服务器上运行它(旧的,我知道)。但是我们得到了错误 Spring数据卡桑德拉手册声称Spring数据2.2.1至少需要卡桑德拉2.1,所以这应该有效,但它没有。我们包含的唯一特定于卡桑德拉的依赖项是 我怎样才能让这个工作?

  • 我在做一个分布式数据库。我试图生成一个唯一的ID,它将作为Cassandra中的列族主键。 我想知道是否有一种方法可以根据时间生成一个唯一的ID?

  • 我是卡桑德拉的新手,我正在尝试使用此CQL查询更新表: 我使用DataTax PHP驱动程序在PHP中工作,此语句的代码如下: 表格: 当我执行语句时,我得到错误“缺少强制的PRIMARY KEY部分域”,因此我添加了子句ALLOW FILTERING: 但是我得到另一个错误,“第1:48行在'允许'处缺少EOF”。这些查询出了什么问题?

  • 我有这个代码: 我得到以下异常: 所有主机尝试查询失败(已尝试:/127.0.0.1:9042(com.datastax.driver.core.TransportException:[/127.0.0.1:9042]无法连接)),堆栈跟踪:com.datastax.driver.core.exceptions.NoHostAvailableException:所有主机尝试查询失败(已尝试:/12