Cassandra+nodejs:如何获取键空间和表?
Cassandra+nodejs: how to get the Keyspaces and Tables?
我正在尝试从 Cassandra 集群获取元数据、键空间和表。我正在使用以下 node.js 代码:
var express = require('express');
var bodyParser = require('body-parser');
var cassandra = require('cassandra-driver');
var client = new cassandra.Client( { contactPoints : [ '127.0.0.1' ] } );
client.connect(function(err, result) {
console.log('Connected To the Database.');
});
var app = express();
app.use(bodyParser.json());
app.set('json spaces', 2);
app.get('/metadata', function(req, res) {
res.send(client.hosts.slice(0).map(function (node) {
return { address : node.address, rack : node.rack, datacenter : node.datacenter }
}));
});
app.get('/metadata/keyspaces', function(req, res) {
client.execute("DESCRIBE KEYSPACES;", function(err, result) {
if (err) {
res.status(404).send(err);
} else {
res.json(result); }
});
});
app.get('/metadata/tables', function(req, res) {
client.execute("DESCRIBE TABLES", function(err, result) {
if (err) {
res.status(404).send({ msg : 'No Table found' });
} else {
res.json(result); }
});
});
var server = app.listen(3000, function() {
console.log('Listening on port %d', server.address().port);
});
问题是,当我 运行 上述代码时,我没有从数据库中获取现有的键空间或表,而是出现以下错误:
{
"name": "ResponseError",
"message": "line 1:0 no viable alternative at input 'DESCRIBE'",
"info": "Represents an error message from the server",
"code": 8192,
"query": "DESCRIBE KEYSPACES;"
}
如何查看这些信息?预先感谢您的帮助。
更新:
我才知道,DESCRIBE 是一个 cqlsh 命令,那么我该如何解决?
DESCRIBE
是仅在 cqlsh 工具上可用的命令。
尝试按照描述查询系统表 here。
键空间列表:
SELECT keyspace_name FROM system.schema_keyspaces;
键空间中的列族列表:
SELECT columnfamily_name FROM system.schema_columnfamilies WHERE keyspace_name = '<keyspace_name>';
我正在尝试从 Cassandra 集群获取元数据、键空间和表。我正在使用以下 node.js 代码:
var express = require('express');
var bodyParser = require('body-parser');
var cassandra = require('cassandra-driver');
var client = new cassandra.Client( { contactPoints : [ '127.0.0.1' ] } );
client.connect(function(err, result) {
console.log('Connected To the Database.');
});
var app = express();
app.use(bodyParser.json());
app.set('json spaces', 2);
app.get('/metadata', function(req, res) {
res.send(client.hosts.slice(0).map(function (node) {
return { address : node.address, rack : node.rack, datacenter : node.datacenter }
}));
});
app.get('/metadata/keyspaces', function(req, res) {
client.execute("DESCRIBE KEYSPACES;", function(err, result) {
if (err) {
res.status(404).send(err);
} else {
res.json(result); }
});
});
app.get('/metadata/tables', function(req, res) {
client.execute("DESCRIBE TABLES", function(err, result) {
if (err) {
res.status(404).send({ msg : 'No Table found' });
} else {
res.json(result); }
});
});
var server = app.listen(3000, function() {
console.log('Listening on port %d', server.address().port);
});
问题是,当我 运行 上述代码时,我没有从数据库中获取现有的键空间或表,而是出现以下错误:
{
"name": "ResponseError",
"message": "line 1:0 no viable alternative at input 'DESCRIBE'",
"info": "Represents an error message from the server",
"code": 8192,
"query": "DESCRIBE KEYSPACES;"
}
如何查看这些信息?预先感谢您的帮助。
更新:
我才知道,DESCRIBE 是一个 cqlsh 命令,那么我该如何解决?
DESCRIBE
是仅在 cqlsh 工具上可用的命令。
尝试按照描述查询系统表 here。
键空间列表:
SELECT keyspace_name FROM system.schema_keyspaces;
键空间中的列族列表:
SELECT columnfamily_name FROM system.schema_columnfamilies WHERE keyspace_name = '<keyspace_name>';