无法使用 cassandra-driver 连接到 cassandra 数据库。
Cassandra 版本是 2.1.5,cassandra-driver 版本是 2.1。
var cassandra = require("cassandra-driver");
var cassandraClient = new cassandra.Client({
contactPoints: [
hostAddress
],
keyspace: [name]
});
cassandraClient.connect(function (err, result) {
if(err) {
console.log('Can not connect to Cassandra host - ', config.cassandra.host);
console.log('Error connecting cassandra is - ', err);
} else {
console.log('Successfully connected to cassandra.');
}
});
cassandraClient.on('log', function(level, className, message, furtherInfo) {
console.log('log event: %s -- %s', level, message);
});