Tag: cassandra

如何将cassandra数据库查询结果读取到节点js中的UI中

我有一个JSfunction router.get('/cassandra', function (req, res) { client.connect(function(err){ }); client.execute('SELECT * FROM monica.emp;', function (err, result) { var user = result.rows[0]; console.log("here is the user", result); } res.render('cassandra',{"cassandra":result}); }); }); 我正在做的是获取第一行，然后访问该行的对象。 但实际的“结果”输出是一组行（集合）像 我如何通过这个设置玉，并在UI页面上显示？ 现在，如果我像下面这样做，我得到未定义的错误。 扩展布局 block content p Cassandra for item in cassandra li a= ' '+ ' '+ item.empid PS我不想使用result.rows [0] result.rows 1 result.rows [2]等访问每一行。我的select […]

什么是目前Cassandra的Node.js驱动程序？

我开始使用Cassandra数据库，我试图find一个像样的node.js驱动程序。 但是一切都很混乱，让我解释一下我发现的东西。 我find的第一个驱动程序是helenus ，我会寻找这个，因为这是本书在开始时提到的那个（仍然是阅读）。 这本书不老， 第一版于2013年December 29, 2013 。 所以不应该这样过时。 然后，在helenus资源库中，我发现这个消息： 如果您使用的是Cassandra 1.2或更高版本，并且您使用的是CQL，则此驱动程序使用旧的Thrift协议，请考虑使用node-cassandra-cql 。 尽pipe我将继续使用此驱动程序修复错误，但由于Thrift不支持许多新function，因此function开发将被冻结。 所以，从逻辑上说，我去了node-cassandra-cql存储库，但是又出现了一条消息： 这不是你正在寻找的驱动程序 node-cassandra-cql从社区驱动程序gradle，成为Apache Cassandra的官方Datastax Node.js驱动程序的基础。 在这一点上，我有点困惑，一切似乎都在变化太快。 我做了一些更多的研究，最后我得到了这三个知识库： Datastax驱动程序 （ jorgebay在其回购中推荐的驱动程序 ） 来自Rackspace的节点Cassandra客户端 阿波罗卡桑德拉（基于Datastax驱动程序） 所以，在这一点上，我有点困惑，我想问一下node.js社区，我应该使用哪些模块在Cassandra上进行开发？ 为什么？ 对于我所看到的，上面没有一个看起来像是我准备好的产品，但是我对卡桑德拉来说是新的，所以也许（当然）我错了。

使用IN查询使用nodejs'cassandra-driver'准备好的查询

这是一个潜在的新手问题，但我无法在野外find答案。 我目前正在build立一个简单的用户事件日志这个表单（一些属性避免这个简单）： CREATE TABLE events.by_hour ( level tinyint, /* 60 = FATAL, 10 = TRACE */ hour int, /* in YYYYMMDDHH format */ insertion_time timeuuid, userid TEXT, message TEXT, PRIMARY KEY ((type,hour),userid,insertion_time)) WITH CLUSTERING ORDER BY (userid ASC, insertion_time ASC); 我想做一个准备好的查询来获取所有的事件，任意过滤一个给定的用户在几个小时的过程中理想的一套水平。 我可以轻松构build查询单个级别和小时的查询： var cassandra = require('cassandra-driver'); var client = new cassandra.Client({contactPoints: ['127.0.0.1']}); var query = […]

如何从node-js中的UUID返回string

使用express-cassandra我正在通过uuidFromString()方法生成一个uuid。 有什么办法可以把它恢复到以前的forms。

检查所有cassandra节点的健康状况

我正在写testing来检查cassandra密钥空间和表的元数据信息。 我也想检查哪个节点已经启动，哪个已经停止。 我该怎么做？

在数据库查询完成之前，Cassandra nodejs eachRow返回

我使用Cassandra与nodejs来获取eachRow大表。 我需要在每一行插入数据，但由于某种原因，它不会等待查询，并在完成之前完成。 client.eachRow(query, [], { prepare: true, autoPage : true, fetchSize: 500 }, function(index, row) { // DB query / insert or update , function(err, result) { // Finish all rows. }); 有什么build议么？

Node.js lsof – 许多打开的数据库连接

当我在我的服务器上运行“lsof | grep node”（运行node.js应用程序）时，我得到了大约1000多行（db连接到端口9160）。 每行看起来像这样： node 17006 root 160u IPv4 1362100969 0t0 TCP localhost:47813->localhost:9160 (ESTABLISHED) 这是一个testingnode.js服务器，做一些非常简单的事情。 （使用Helenus模块将请求logging到Cassandra DB） 我很惊讶有这么多的开放式的连接，现在肯定不应该有1-2个连接。 这是否意味着我不能在Node应用程序中正确结束我的数据库连接？ 我的代码如下。 谢谢。 var express = require('express') , routes = require('./routes') , app = express.createServer(); app.configure(function(){ app.use(express.bodyParser()); app.use(express.methodOverride()); app.use(app.router); }); process.on('uncaughtException', function (err) { logger.error('Caught exception: ' + err); }); function respond_test(req, res, next) { var […]

我如何让Helenus返回CQL查询的实际值？

我使用Helenus的Node.js连接到Cassandra DB。 我有一个查询：SELECT score FROM team_scores WHERE team_name ='foo' 从cqlsh运行时，我得到的结果如下所示： score ——- 10 然后，我使用cqlVersion 3.0.0将查询移动到Node和Helenus。 当我运行这个代码： pool.cql("SELECT score FROM team_scores WHERE team_name = 'foo'", function(err, results){ console.log(results); }); 控制台报告： [ <Row: Key: 'foo', ColumnCount: 1, Columns: [ 'score' ]> ] 我错过了什么让Helenus回报我的分数的实际价值，而不是似乎返回？

如何将Node.js与Cassandra连接？

我一直试图将Node.js与本地主机上的Cassandra连接50年（感觉就像这样），但还没有弄清楚它们是如何一起工作的。 我将不胜感激任何可能导致解决scheme的build议。 项目目录： 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工作没有任何问题，所以webpackconfiguration中不存在这个问题。 […]

使用cassandra和elasticsearch后端制作我的titan db图

我的问题是，我想将产品，客户和销售商数据存储在以cassandra作为存储后端和elasticsearch作为索引后端的titangraphics数据库中。 然后我会查询这些数据，向顾客和卖家提供build议。 我无法达到我可以存储自己的数据的地步。因为数据将是巨大的，我将使用cassandra和elasticsearch。 我到目前为止所做的是，我有cassandra，elasticsearch成立。 现在我可以运行bin / titan.sh启动启动cassandra，es和gremlin服务器我也可以用神数据图来玩 gremlin> graph = TitanFactory.open('conf/titan-cassandra-es.properties') ==>standardtitangraph[cassandrathrift:[127.0.0.1]] gremlin> GraphOfTheGodsFactory.load(graph) ==>null 现在我试图find一种方法来存储我的产品，客户和销售商graphics数据。 这样它的存储在cassandra和索引上就是elasticsearch。 我应该采取什么措施来做到这一点。 我的项目的主要语言是nodejs和Java是由于项目的限制。 我的问题简而言之 如何存储我自己的数据为titanium的数据库进行处理 一旦数据可用于处理。 我会暴露一些http apis来提出build议。 在Java中写作由于一些限制而不成问题。 我应该如何继续（我想我只有gremlin作为替代） 如果你能指出我的错误，并朝正确的方向扔掉一些面包屑，我将不胜感激