node.js node-cassandra-client请求失败

当我试图查询Cassandra服务器时,遇到同样的问题。 我有npm安装node-cassandra-client版本0.9.5。

var Connection = require('cassandra-client').PooledConnection; var hosts = ['host1:9160','host2:9160']; var cassandra = new Connection({'hosts': hosts, 'keyspace': 'keyspace'}); cassandra.on('log', function(level, message, obj) { console.log('log event: %s -- %j', level, message); }); var cql = "SELECT * FROM columnFamily LIMIT 1"; cassandra.execute(cql, function(err, rows) { if(err) console.log("erreur à la requete"); console.log(rows); cassandra.shutdown(function() { console.log("connectoin pool shutdown"); }); }) 

看起来连接成功了。 但我一直遇到以下错误:

 log event: info -- "connecting host:9160(1)" log event: cql -- "SELECT * FROM columnFamily LIMIT 1" DEBUG: DEBUG: /PATH/cassandra-client/node_modules/thrift/lib/thrift/connection.js:90 DEBUG: throw e; DEBUG: DEBUG: ^ DEBUG: TypeError: undefined is not a function at /PATH/node_modules/cassandra-client/lib/driver.js:701:5 at /PATH/node_modules/cassandra-client/lib/driver.js:716:15 at /PATH/node_modules/cassandra-client/lib/driver.js:453:9 at/PATH/node_modules/cassandra- client/node_modules/thrift/lib/thrift/connection.js:80:11 at Object.recv_execute_cql_query (/PATH/node_modules/cassandra-client/lib/gen-nodejs/Cassandra.js:6219:12) at /PATH/node_modules/cassandra-cli ent/node_modules/thrift/lib/thrift/connection.js:83:37 at Socket.<anonymous> (/PATH/node_modules/cassandra-client/node_modules/thrift/lib/thrift/transport.js:69:9) at Socket.emit (events.js:67:17) at TCP.onread (net.js:347:14) DEBUG: Program node app.js exited with code 1 

不pipe要求是什么,我都会有同样的错误。

我知道这有点晚,但是当它接受三个参数(查询,查询参数列表和callback)时,你用两个参数(查询和callback)调用cassandra.execute

尝试改变:

  cassandra.execute(cql, function(err, rows) { if(err) console.log("erreur à la requete"); console.log(rows); cassandra.shutdown(function() { console.log("connectoin pool shutdown"); }); }) 

  cassandra.execute(cql, [], function(err, rows) { if(err) console.log("erreur à la requete"); console.log(rows); cassandra.shutdown(function() { console.log("connectoin pool shutdown"); }); })