如何将node.js应用程序正确连接到cassandra节点?

to94eoyn  于 2021-06-14  发布在  Cassandra
关注(0)|答案(1)|浏览(428)

我有两个cassandra节点托管在两个ip上。现在,当我从windows通过node.js中的cassandra驱动程序连接到其中一个节点时,会出现“连接超时”和“主机无法访问”之类的错误。但是,我可以从网络外部通过cqlsh连接到这些节点。
我做错什么了吗?下面是示例代码。

var cassandra = require('cassandra-driver');

var uuid = require('uuid')
var client = new cassandra.Client({ contactPoints: ['(PUBLIC IP Here) X.X.X.X:9042'], localDataCenter: 'datacenter1', keyspace: 'ksks' });

function getAllPersons() {
    var query = 'SELECT * FROM person';
    return new Promise((resolve, reject) => {
        client.connect(function (err) {
            if (err) return console.error(err);
            else {
                client.execute(query, function (err, result) {
                    if(err)  {
                        reject([])
                    }
                    else {
                        if(result.rows.length) {
                            resolve(result.rows);
                        }
                        else {}
                            reject([])
                    }
                });
            }
        });
     });
}

在cassandra.yaml中,我有以下值:

listen_address: 10.0.0.4
native_transport_port: 9042
rpc_address: 10.0.0.4
rpc_port: 9160
api_port: 10000
api_address: 10.0.0.4

我需要改变什么?这些节点工作正常,可以相互连接(也可以从远程网络)。

wfveoks0

wfveoks01#

如果使用公共ip远程访问群集,则配置不正确。
此表可能有助于您在scylla.yaml中找出正确的IP: https://docs.scylladb.com/operating-scylla/procedures/cluster-management/ec2_dc/#ec2-configuration-table 除非使用aws,否则不要使用ec2snitch。这张table只是一个参考资料。

相关问题