我们运行的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
}
});
问题是我的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