Tag: cassandra

在回送io中同步执行: 我在回环io框架中使用Cassandra nodejs连接器。由于回送没有inbuild cassandra连接器我正在使用nodejs cassandra连接器。此外，我正在使用remotehook回环调用我的自定义方法时调用restapi。在beforeremote（）方法中，我需要通过我的cassandra db表来validation来自api的less量input。我有3个input键在restAPI，需要validation在卡桑德拉3表，我已经创build了3个方法。问题是我需要逐一validation它，并且在cassandra中有asynchronous方法。我怎样才能以同步的方式实现这一点，因为所有三个validation应该以同步的方式一个接一个地进行。如果需要，我可以发布代码。

显示缓冲区types数据的string的cassandra timeuuid列: 我正在使用NodeJS Cassandra驱动程序从Cassandra timeuuid列中检索数据。现在，数据被检索为缓冲区types而不是stringtypes。我需要数据作为stringtypes

如何用Cassandra Consistencies定义TYPES？: 我有以下几点： var cassandra = require('cassandra-driver'); var clientCass = new cassandra.Client({ contactPoints: ['localhost'], keyspace: 'localhost' }); 迈向代码的底部，我正在这样做： //Now add a row or Check to see if the session already exists var query = "INSERT INTO localhost.shirosessions (id,expired,last_access_ts,start_ts) \n\ VALUES ('" + theSession.sessionid + "',false,'" + component.getTimeStampA() + "','" + component.getTimeStampA() + "') IF NOT EXISTS"; //var […]

nodejs-cassandra不会插入整数: 我已经尝试了很多东西来得到这个固定的，但总是似乎导致了一个或另一个错误。下面是我用来执行INSERT查询的代码。 req.client.execute("INSERT INTO users (id,username,email,password,userFolder) VALUES (now(),'"+newUser.username+"','"+newUser.email+"','"+newUser.password+"',"+newUser.userFolder+");",function(err,result){ if(err){ console.log(err.message) }else{ console.log("New user created") } }); newUser.userFolder在数组中简单地定义为new Date().getTime() ive尝试做parseInt(userFolder: new Date().getTime()); 但似乎总是导致这个错误另外，如果您尝试Number(userFolder :new Data().getTime()); 它也不起作用，并导致下面的第二个错误; 我尝试的另一件事是简单地inputnewUser.userFolder.valueOf()这也导致第二个错误。 Invalid STRING constant (1443827057269) for "userfolder" of type int 要么 Unable to make int from '1443827264655' 我有一种感觉，因为这个数字是在这之前造成的。但我不知道如何删除这个。我试图直接input数字，而不使用数组，它工作正常，所以variables必须导致这个问题。我基本上从MySQL迁移到卡桑德拉，并有这个项目的最后期限，所以任何帮助，将不胜感激。顺便说一下使用datastax驱动程序的节点-JS

如何通过node.jsclosures与cassandra的连接: 如何在node.js中closures与Cassandra的连接？如果我没有closures连接，我会遇到一个错误。错误是错误： All host(s) tried for query failed. First host tried, 10.XXXXX:OOO: Error: connect EMFILE 我已经在datastax中看到了解决scheme。这表明它可以通过命令process.exit()来解决。但它会杀死整个node.js进程。那不是我想要的。我只想closurescassandra连接而不是整个node.js进程。有没有人有这个好的解决scheme？

Cassandra手册分页：将pageState公开给客户端（在nodeJS中）: 将pageState公开给客户端是否安全？它是链接到原始查询，还是我可能暴露其他数据？在我目前的实现中，客户端可以发送任何东西作为pageState。长话短说：我正在NodeJ上构buildREST api，并从Cassandra集群中获取我的数据。由于查询有相当大的结果，我需要做一些分页。我得到了手动分页工作，但在我目前的实现中，我发送pageState到客户端，并将其发送回来，以获得下一批结果。 if(req.query.page) { options.pageState = new Buffer(req.query.page,'hex'); }; client.eachRow(query, [], options, function (n, row) { arr.push(row); }, function (err, result) { res.send({ values: arr, next: result.pageState }); }); 另一个想法是将其保存在某种caching中，并向客户端发送一个id。我会发送该服务器和客户端之间的id，并且pageState不能被修改。只是想知道这是开销，还是实际需要。谢谢。

应用程序应该连接到cassandra的SEED NODE或CLUSTER NODE吗？: 基于NodeJS的应用程序正在使用Cassandra（1个种子节点和2个节点）。 Cassandra应该与Seed节点还是Regular节点连接？它是一样的吗？谢谢

是否有可能使用Cassandra和Node.js？: 我想尝试Cassandra，但不知道如何将Cassandra与Node.js集成。当我说Node.js是MEAN.JS或任何其他框架。只要让我知道，如果有一种方式？

使用nodejs脚本将GB的数据从MongoDB迁移到Cassandra的最佳方法: 我在MongoDB中有一个很大的集合。希望通过在该数据上运行一些业务逻辑nodejs脚本来迁移所有数据到cassandra。做这个的最好方式是什么？我编写了一个脚本，在mongo的单个请求中处理5000个文档，处理数据并将文档插入到cassandra中。经过40-50次迭代需要很多时间。 CPU使用率显示100％。这是因为很多callback发生？我是节点j的新手，所以不能完成任何事情。var cassandra = require（'../ models / tracking_cassandra'）; var TrackingEvents = require（'../ models / tracking_mongo_events'）; var counter = 0; var incr = 5000; var final_counter = 0; var start_point = function (callback){ TrackingEvents.count(function(err, data){ final_counter = data; TrackingEvents.getEventsByCounter(counter, function(counter, obj) { var prevId = obj[0].toObject()._id; getMessagesFromMongo(prevId, callback); }); […]

用NodeJS的UUID查询Cassandra: 感谢您花时间看我的问题。我和我的团队刚刚开始涉足NodeJS，这是我们第一次遇到一个问题，至今我们还找不到解决scheme。简而言之，我们有一个Controller，需要用一个UUID主键来查询Cassandra。控制器： 'use strict'; const express = require('express'); const models = require('../dbConnection'); const router = express.Router(); var UUID = require('uuid-js'); // Store / create checklist definition. router.post('/', function(req, res) { }); // Show checklist definition. router.get('/:id', function(req, res) { let checklistId = req.params.id; console.log(checklistId); models.instance.ChecklistDefinition.findOne({id: checklistId}, function(err, checklist) { if (err) { console.log(err); […]