node.js - 从 Node.js 远程写入 Cassandra 服务器时遇到问题

Question

环境:操作系统:Debian、Cassandra:3.10、Node.js 7.5.0、cassandra-driver:3.2.0

错误:( Node :7484)UnhandledPromiseRejectionWarning:未处理的 promise 拒绝(拒绝 ID:1):错误:尝试查询的所有主机均失败。尝试的第一个主机，192.168.10.151:9042:错误:连接ECONNREFUSED 192.168.10.151:9042。请参阅innerErrors。( Node :7484) DeprecationWarning:未处理的 promise 拒绝已被弃用。将来，未处理的 Promise 拒绝将会以非零退出代码终止 Node.js 进程。

Nodejs 代码:

var express = require('express');
var router = express.Router();
var bodyParser = require('body-parser');
var fs = require('fs');
var cassandra = require('cassandra-driver');
var async = require('async');
var client = new cassandra.Client({contactPoints: ['192.168.10.151'], keyspace: 'users'});

router.post('/', function(req, res, next) {
    var query = 'INSERT INTO userAuth(email,password) VALUES(req.body.email,req.body.password)';
    client.execute(query);
    });

module.exports = router;

我不确定我做错了什么。

Answer 1

您的插入语句似乎也无效。你可以尝试一下

'插入 userAuth(电子邮件、密码) VALUES(?,?)'

然后

执行(查询，[req.body.email，req.body.email])；

加上我认为添加查询结果处理功能可能是个好主意

function(n, row) {
    console.log('everything is o.k.');
},
function (err) {
   console.log('something went wrong', err);
}

而且该错误似乎与此非常相似，因此尝试将 cassandra.yaml 文件中的广播地址更新为 192.168.10.151

dse-driver connection refused