Tag: cassandra

“中止”cassandra结果的阅读: 我有一个cql，我需要执行和使用node.js驱动程序stream结果。但是，如果满足某个条件，我需要中止stream式传输。像这样的东西： client.eachRow(cql, [], { autoPage: true }, function(n, row) { if(applySomeFilterLogic(row) === 'some val') { //abort streaming } else { rows.push(row); } }, function(err, result) { logger.error("server responded with error : %s", err); }); 数据不能用过滤逻辑进行预处理，并保留在cassandra中。它需要在运行时计算，基于一些数据持久化时不知道的标准。有没有办法通过node.js驱动程序或cassandra来优雅地实现这一点？

为我的节点应用程序select正确的数据库: 我是新的节点js＆我需要build议为我的节点应用程序select数据库。比方说，我的名单上有几个游戏（以千计）。数组应该看起来像这样： { "Football": { "John": [{ "age": "1", "weight": "2", "height": "3", }], "Smith": [{ "age": "11", "weight": "22", "height": "33", }], … }, "Golf": { "Ricky": [{ "age": "4", "weight": "5", "height": "6", }], "Jonathan": [{ "age": "44", "weight": "55", "height": "66", }], … }, … /* Thousand more to go */ […]

无法连接到scassandra（残桩cassandra）使用datastax驱动程序: 我有麻烦连接到cassandra。我试图连接到s-cassandra（这是一个残桩cassandra可以在这里审查），一个datastax node.js cassandra驱动程序。由于某些原因，将“127.0.0.1:8042”作为接触点传递给驱动程序会导致DriverInternalError ：（强硬有时它确实随机工作，我还没有弄清楚为什么有时候会这样做，有时我不会..） DriverInternalError我得到： {“name”：“DriverInternalError”， “stack”：“…”， “消息”：“本地数据中心无法确定”， “info”：“代表驱动程序或Cassandra主机中的错误。” } 这就是我从Cassandra Driver日志中看到的： log event: info — Adding host 127.0.0.1:8042 log event: info — Getting first connection log event: info — Connecting to 127.0.0.1:8042 log event: verbose — Socket connected to 127.0.0.1:8042 log event: info — Trying to use protocol version 4 […]

我无法从docker容器中的nodejs应用程序连接到cassandra: 我有一个nodejs应用程序在一个docker容器（节点：7.8.0）使用“桥”networking。我使用cassandra驱动程序与cassandra服务器连接，但初始化连接时会引发超时exception： Error: The host 172.16.210.101:9042 did not reply before timeout 12000 ms at OperationTimedOutError.DriverError (node_modules/cassandra-driver /lib/errors.js:14:19) at new OperationTimedOutError (node_modules/cassandra-driver/lib/errors.js:104:33) at Connection.onTimeout (node_modules/cassandra-driver/lib/connection.js:645:20) at Timeout._onTimeout (node_modules/cassandra-driver/lib/connection.js:620:10) at ontimeout (timers.js:386:14) at tryOnTimeout (timers.js:250:5) at Timer.listOnTimeout (timers.js:214:5) 从容器内部，我可以ping通cassandra服务器并执行telnet连接。使用“主机”networking工作，并在“标准”环境中执行应用程序。任何帮助是欣赏。

我的cassandraconfiguration是否正确: 在正常情况下，我有一个cassandra集群，有三个节点。当我从node.js发送写请求集群时，我希望所有的节点在写入完成后写回给我，而在读取时，我希望能够读取我连接的节点。当三个节点中的一个死亡时，我希望这个设置继续。我select了复制因子= 3一致性= 2我应该如何实现configuration。 configuration是否正确？我的敬意

如何在nodejs cassandra驱动程序中为查询设置密钥空间？: 我正在尝试使用cassandra-driver进行查询，指定键空间作为选项，但遇到错误“没有指定键空间”。我正在使用下面的代码 connection = new driver.Client({ contactPoints: ['abc'] }); connection.execute(query, { keyspace: 'system_schema' }) 任何人都可以帮我理解我错过了什么吗？

Cassandra客户端不会插入: 我不确定为什么这不起作用。我的表很简单（我甚至改变了一切varchar的暂时），我可以INSERT，如果我使用cqlsh。 var Connection = require('cassandra-client').Connection; var db = new Connection({host: 'cassbx01.qualcomm.com', port: 9160, keyspace: 'foursq'}); db.execute("INSERT INTO checkins (fqid, name, address, city, state, zip, country, lat, lng, hereNow) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", [value.id, value.name, value.location.address, value.location.city, value.location.state, value.location.postalCode, value.location.country, value.location.lat, value.location.lng, value.hereNow.count], function (err) { if […]

Cassandra驱动程序在php，java，python，node.js中的拓扑意识: 我只是好奇。 Cassandra驱动程序是否意识到拓扑结构？这意味着驱动程序知道哪个机架最靠近哪个机架，哪个节点最有可能保存数据，并且具有低延迟以减less请求的响应时间？还是每个司机都知道这个？你会推荐哪些图书馆？我非常感谢你的帮助。

cassandra节点驱动程序不接受短划分的string: 我使用这个驱动程序作为cassandra和我的节点js应用程序之间的桥梁。除了下面的问题，一切似乎一直运行良好：问题我有一个types的varchar列，当我插入一个string中有破折号（ – ），然后cassandra抛出错误String didn't validate. 。我正在使用如下所示的批处理语句 var queryset_insert_user = { query: query_insert_user, params: query_insert_user_params, hints:[ dataTypes.varchar, dataTypes.varchar, dataTypes.varchar, dataTypes.varchar, dataTypes.varchar, dataTypes.varchar, dataTypes.varchar] } 其中varchar是 var dataTypes = {}; dataTypes.varchar = 0x000d; //couldn't find how to get this from API itself so just copied value from types.js of cassandra driver. 批语是 var batchQueries […]

卡桑德拉：操作超时: 我正在使用cassandra节点JS驱动程序，我得到以下错误： error: Database error found %s . On selectAllJobs() call { name: 'ResponseError', message: 'Operation timed out – received only 0 responses.', info: 'Represents an error message from the server', code: 4608, consistencies: 1, received: 0, blockFor: 1, isDataPresent: 0, query: 'SELECT * FROM cron_tasks WHERE type =? AND starts < ? ALLOW FILTERING ;' […]