如何将 Node.js 与 Cassandra 连接起来？

Question

50 年来，我一直在尝试将 Node.js 与 Cassandra 连接到 localhost（感觉不错），但还没有弄清楚它们是如何协同工作的。我将不胜感激任何可能导致解决方案的建议。

项目目录：

project  - app - some files
        \- build - index.js, index.html, etc.(I start the server by "node index.js")
        \- node_modules - some modules
        \- signup - some files to be minified
        \- signin - some files to be minified
        \- apache-cassandra-3.0.6 - bin, conf, etc.(downloaded from tarball)
        \- package.json
        \- webpack.config.js

Webpack 运行没有任何问题，所以问题在 webpack 配置中不存在。
我可以使用cqlsh插入数​​据，所以问题不在于数据结构的模型。

我认为问题在于我对如何同时使用 Node.js 和 Cassandra 缺乏了解。

我将 Node.js 与 Cassandra 连接的过程：

1. 进入构建目录
2. node index.js
3. 打开localhost:3000找到首页，通过express.js路由，显示没有问题。
4. 转到注册页面并提交表单
5. 错误（未插入数据）

---

我不确定哪个联系点是正确的，“127.0.0.1:9042”或“127.0.0.1”

var client = new cassandra.Client({contactPoints:['127.0.0.1:9042']});
                   OR
var client = new cassandra.Client({contactPoints:['127.0.0.1']});

我这样设置我的路由器。

var router = express.Router();
var insertUser = 'INSERT INTO keyspace.users (username, create_time, email, password) VALUES (?, ?, ?, ?);';

router.get"/", function(req, res) {
  res.sendFile(__dirname + '/index.html'); // This is working.
});

router.post("/signup", function(req, res) {
  var username = req.body.username;
  var email = req.body.email;
  var password = req.body.password;
  client.execute(insertUser, [username, now(), email, password], 
  { prepare: true }, function(err) {
    if (err) {
      console.log("error"); // I receive error.
    } else {
      console.log("success");
    }
  });
});

我应该让 cassandra 像这样在后台运行吗？

cd apache-cassandra-3.0.6 -> cd bin -> ./cassandra

我在这里错过了什么？

Answer 1

根据您提供的错误消息，您的 Cassandra 实例上似乎设置了 PasswordAuthenticator 身份验证或其他身份验证器。检查 cassandra.yaml 文件中的“身份验证器”属性，是否设置为 PasswordAuthenticator、AllowAllAuthenticator 或其他？

如果使用PasswordAuthenticator，您可以通过将PlainTextAuthenticator 实例作为authProvider 传递给您的客户端选项来指定凭据：

var PlainTextAuthProvider = cassandra.auth.PlainTextAuthProvider;
var client = new cassandra.Client({ contactPoints:['127.0.0.1:9042'], 
                                    authProvider: new PlainTextAuthProvider('cassandra', 'cassandra')};

使用身份验证时可用的默认用户是“cassandra”，密码为“cassandra”，但您可以通过关注Configuring Authentication 进行更改。