11

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

リクエストが何であれ、同じエラーが発生し続けます。

4

1 に答える 1

2

少し遅れていることはわかっていますが、2 つのパラメーター (クエリとコールバック) を使用して呼び出しcassandra.executeていますが、3 つのパラメーター (クエリ、クエリ パラメーターのリスト、およびコールバック) を受け入れています。

変更してみてください:

 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");
     });
 })
于 2012-11-08T13:54:47.397 に答える