如何使用 Gremlin 连接 Node js 和 cassandra DSE 图?连接不工作
How to connect Node js with cassandra DSE graph using Gremlin? connection not working
我尝试在使用 gremlin 的 DSC 中将节点 js 连接到 Cassandra DB。如何连接 Cassandra 数据库?
我正在使用
1.Node js,
2.Express js,
3.卡桑德拉数据库,
4.Data 堆栈工作室 (DSE),
5.Gramlin 查询(nosql)。
我尝试了这两种方法,但无法 connect.How 我可以连接 Cassandra DB、DSE 并使用 Gramlin 查询吗?谢谢。
//1.I tried this one first
var dse = require('dse-driver');
var dse_driver = new dse.Client({
contactPoints: ['127.0.0.1'],
protocolOptions: {
port: 9042
},
graphOptions: {
name: 'Demo_work_graph'
}
});
//2.I use this one also
var cassandra = require('cassandra-driver');
var async = require('async');
var client = new cassandra.Client({ contactPoints: ['127.0.0.1'], graphOptions: {name: 'Demo_work_graph'} });
我遇到了这个错误
error { Error: line 1:0 no viable alternative at input 'g' ([g]...)
at ResponseError.DriverError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:20:19)
at new ResponseError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:57:24)
at FrameReader.readError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/readers.js:338:13)
at Parser.parseBody (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:200:66)
at Parser._transform (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:143:10)
at Parser.Transform._read (_stream_transform.js:186:10)
at Parser.Transform._write (_stream_transform.js:174:12)
at doWrite (_stream_writable.js:385:12)
at writeOrBuffer (_stream_writable.js:371:5)
at Parser.Writable.write (_stream_writable.js:288:11)
name: 'ResponseError',
stack: 'Error: line 1:0 no viable alternative at input \'g\' ([g]...)\n at ResponseError.DriverError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:20:19)\n at new ResponseError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:57:24)\n at FrameReader.readError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/readers.js:338:13)\n at Parser.parseBody (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:200:66)\n at Parser._transform (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:143:10)\n at Parser.Transform._read (_stream_transform.js:186:10)\n at Parser.Transform._write (_stream_transform.js:174:12)\n at doWrite (_stream_writable.js:385:12)\n at writeOrBuffer (_stream_writable.js:371:5)\n at Parser.Writable.write (_stream_writable.js:288:11)',
message: 'line 1:0 no viable alternative at input \'g\' ([g]...)',
info: 'Represents an error message from the server',
code: 8192,
coordinator: '127.0.0.1:9042',
query: 'g.V()' }
你应该使用 dse-driver:
const client = new dse.Client({
contactPoints: ['host1'],
graphOptions: {
name: 'Demo_work_graph'
}
});
client.executeGraph('g.V().count()')
.then(console.log)
.catch(console.error);
我尝试在使用 gremlin 的 DSC 中将节点 js 连接到 Cassandra DB。如何连接 Cassandra 数据库? 我正在使用 1.Node js, 2.Express js, 3.卡桑德拉数据库, 4.Data 堆栈工作室 (DSE), 5.Gramlin 查询(nosql)。 我尝试了这两种方法,但无法 connect.How 我可以连接 Cassandra DB、DSE 并使用 Gramlin 查询吗?谢谢。
//1.I tried this one first
var dse = require('dse-driver');
var dse_driver = new dse.Client({
contactPoints: ['127.0.0.1'],
protocolOptions: {
port: 9042
},
graphOptions: {
name: 'Demo_work_graph'
}
});
//2.I use this one also
var cassandra = require('cassandra-driver');
var async = require('async');
var client = new cassandra.Client({ contactPoints: ['127.0.0.1'], graphOptions: {name: 'Demo_work_graph'} });
我遇到了这个错误
error { Error: line 1:0 no viable alternative at input 'g' ([g]...)
at ResponseError.DriverError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:20:19)
at new ResponseError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:57:24)
at FrameReader.readError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/readers.js:338:13)
at Parser.parseBody (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:200:66)
at Parser._transform (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:143:10)
at Parser.Transform._read (_stream_transform.js:186:10)
at Parser.Transform._write (_stream_transform.js:174:12)
at doWrite (_stream_writable.js:385:12)
at writeOrBuffer (_stream_writable.js:371:5)
at Parser.Writable.write (_stream_writable.js:288:11)
name: 'ResponseError',
stack: 'Error: line 1:0 no viable alternative at input \'g\' ([g]...)\n at ResponseError.DriverError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:20:19)\n at new ResponseError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/errors.js:57:24)\n at FrameReader.readError (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/readers.js:338:13)\n at Parser.parseBody (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:200:66)\n at Parser._transform (/home/periyasamy/K12OS/server/node_modules/dse-driver/lib/streams.js:143:10)\n at Parser.Transform._read (_stream_transform.js:186:10)\n at Parser.Transform._write (_stream_transform.js:174:12)\n at doWrite (_stream_writable.js:385:12)\n at writeOrBuffer (_stream_writable.js:371:5)\n at Parser.Writable.write (_stream_writable.js:288:11)',
message: 'line 1:0 no viable alternative at input \'g\' ([g]...)',
info: 'Represents an error message from the server',
code: 8192,
coordinator: '127.0.0.1:9042',
query: 'g.V()' }
你应该使用 dse-driver:
const client = new dse.Client({
contactPoints: ['host1'],
graphOptions: {
name: 'Demo_work_graph'
}
});
client.executeGraph('g.V().count()')
.then(console.log)
.catch(console.error);