Tag: asynchronous

node-horsemanasynchronous不起作用?

我正在使用node-horseman(希望)允许我执行asynchronousphantomjs操作来实现asynchronous无头浏览。 数组中的数字在这个阶段是不相关的,我只是将代码剥离到最低限度,以演示我遇到的问题。 当我运行下面的代码时,它运行asynchronous,但是,一旦我创build一个新的骑士,它将停止asynchronous运行。 我知道它没有运行asynchronous,因为输出(控制台logging数字)以线性方式发生,每个数字在统一的时间之后显示。 运行它asynchronous它应该是瞬间的,因为显示每一个的开销应该是相同的,所以所有的数字应该同时出现在他们没有创build骑马对象时的方式(如下面的代码对象禁用)。 var Horseman = require('node-horseman'); var async = require('async'); var testArray = [ 1, 2, 3, 4, 5 ]; function evaluate( item ) { console.log( item ); /*It runs asynchronously but if the two lines below are activated it stops being async and runs synchronously, defeating the whole purpose of using […]

我怎么能promisify我写的一个简单的asynchronous函数?

build立 在为Node编写一些数字Javascript代码的时候,发生了这样的想法:“为什么不使这个asynchronous呢? 例如, var mySquare = function(x, callback) { callback(null, x * x); } mySquare(3, function(err, res) { console.log(res); }); // prints 9 除非有更复杂的计算,而且可能会引发错误。 题 我怎么promisify这个function,而不重写它使用承诺? 使用蓝鸟的promisify ,通过var promisedSquare = Promise.promisify(mySquare) ,返回一个错误堆栈: TypeError: undefined is not a function at l (/path/bluebird.min.js:30:15474) at Function.e.promisify (/path/bluebird.min.js:30:16031) at repl:1:30 … 它几乎看起来像蓝鸟试图评估mySquare 。 我没有像d3.json (包装XHR)promisifying库函数没有问题,所以我很困惑:我需要提供比任何比callback驱动的asynchronous函数更多的蓝鸟?

async.each在完成所有迭代后callback

现在我已经一头撞在这段代码上几个小时了。 而且我之前多次使用过“ async.each ”。 可能是代码只是需要一组不同的眼睛来工作。 这是代码和问题。 async.each(process.argv, function(file, callback){ runFile(file, callback); }, function(err){ console.log("Here is the error!:" + err +"files to unstage: " + filesToUnstage) if(err) console.log(err); else{ if(filesToUnstage) { __unstage(); } } }); RUNFILE: function runFile(filename, callback) { // Do a bunch of stuff …. __parseOutput(output, callback); } __parseOutput: function __parseOutput(output, callback){ //Do some […]

Meteor wrapAsync不会在客户端返回值

我正在尝试使用Meteor.wrapAsync使用Slingshot上传文件,然后获取上传URL。 我已经创build了这个函数,但是当我运行它时,image_url会变成未定义的。 该图像虽然成功上传。 获取图片url var uploadSlingshotFileSync = Meteor.wrapAsync(uploadSlingshotFile); image_url = uploadSlingshotFileSync(image_file); console.log(image_url); function uploadSlingshotFile = function(file, callback) { var uploader = new Slingshot.Upload("photoUploads"); uploader.send(file, function (error, uploadURL) { callback(null, uploadURL); }); }; 有什么我想念wrapAsync的语法?

pipe道过滤和lodash处理

我有以下lodash伪代码,这将处理auctions : var auctions = [{'item': 12345, …}, {'item': 12345, …}, {'item':23436, …}]; var process = function(auctions) { _(auctions) .groupBy('item') .thru(processSpecialItems) .each(processCommonItems) .value(); } 每个函数都依赖于前一个函数的结果,但在processSpecialItems和processCommonItems的情况下: 只有特定的item ,即。 由给定item值标识的组将由processSpecialItems处理。 只有那些没有被处理的团体应该继续处理共同的processCommonItems 。 这些操作是CPU密集型的,涉及数据库访问。 问题: 我怎样才能过滤这些特殊的物品,处理它们,然后把剩下的东西还回来? 最好尽可能less的通过,因为data包含超过40,000个项目。 使用同步迭代是否可接受,性能明智? 这段代码将被执行400次(全部在同一时间)。

使用MariaDB批量插入和删除Waterline / Sails.js

在我的Sails.js应用程序中,我有一个表auctions ,它包含从Battle.net API最后一次转储所收到的数据。 因此,每当一个realm的新的转储到达时,我需要清除所有与这个realm相关的行,然后插入新的领域。 我可以这样做: 一次性发送(使用destroy()发送一个查询,另一个使用自身的转储); 或者小批量(按item分组,然后用realm和项目destroy()所有logging,然后插入新logging)。 我目前正在使用async.forEachOfSeries来完成上述的小批量操作,但是当前的负载(每次运行作业时都会插入45k条logging),速度太慢了,这并不考虑是否需要更新item工具提示logging。 如果我试图一次插入它们,Node.js会启动分页并挂起,或者MariaDB比Waterline允许的时间要长。 我怎样才能更加可扩展地解决这个问题? 会async.queue或async.cargo工作?

如何在Node.js中创build一个API请求响应stream?

我从一段时间以来一直在使用Node.js的asynchronousfunction。 但是我陷入了一个有趣的问题。 基本上我有2个API,我需要一个接一个地调用。 由于Node.js的asynchronous性质,我不能检索第一个API请求的响应,直到它完成并调用相应的callback函数。 我想要做的是,我想要将第一个API作为请求负载的响应传递给第二个API,而不是等到第一个API完全完成。 作为一种可能的替代scheme,我应该从构buildrest API转换到streamAPI吗? 任何指针如何做到这一点? 谢谢

等待NodeJS中的asynchronous方法

我看起来高低,只能find如何编写asynchronous函数,我已经明白了。 我试图做的是在触发的事件[EventEmitter]中运行asynchronous方法,但是这样一个简单的事情似乎只是根本不可能,因为我可以find。 考虑以下… // Your basic async method.. function doSomething(callback) { var obj = { title: 'hello' }; // Fire an event for event handlers to alter the object. // EvenEmitters are called synchronously eventobj.emit('alter_object', obj); callback(null, obj); } // when this event is fired, I want to manipulate the data eventobj.on('alter_object', function(obj) { obj.title […]

Nodejs混合了asynchronous函数和promise

所以我有一些帮助服务的应用程序,使它更容易创build和获得复杂的模型。 其中一个是 getMerits: function(profileId, limit){ return async.waterfall([ function(callback){ Merit.find({employeeProfile: profileId}).then(function(merits){ callback(null, merits); }); }, function(merits, callback){ async.forEach(merits, function(item, loop_callback){ MeritIndex.findOne({id: item.index}).then(function(meritIndex){ merits[merits.indexOf(item)].index = meritIndex; loop_callback(); }); }, function(err, results){ callback(null, merits); }); } ], function(err, results){ return results; }); } 麻烦的是当我试图调用这个函数来得到结果(插入价值指数列表)我不能找出正确的方法来从asynchronous瀑布返回结果: async.forEach(profiles, function(item, loop_callback){ MeritService.getMerits(item.id, 5).exec(function(err, merits){ console.log(merits) profiles[profiles.indexOf(item)].merits = merits; loop_callback(); }); // MeritService.getMerits(item.id, […]

nodeJSdevise模式打破了asynchronousstream水或承诺。然后,然后

我有4个asynchronous函数在瀑布式我的节点应用程序中执行。 async.waterfall会把它整理一下,但是根据第一个函数的结果,我要么是错误的,要么进行瀑布或者是爆发到完成的function。 目前没有办法做到这一点(除了错误,成功的价值,只是闻起来不好)。 我正在看使用诺言(蓝鸟),但是,我再也看不到有什么办法可以突破,如果我没有在那个时候再给出另外一个诺言,那么下面的所有内容都会被执行。参数。 有其他的模式/工具可以帮助吗? 或者我在想这个,只是调用第一个方法,然后根据结果运行async.waterfall,或返回结果! 假设我有4个函数可以调用,a,b,c,d ….. async.waterfall([ function(cb) { a("some data", cb) }, function(data, cb) { if(data) { // HERE we want to skip the remaining waterfall a go to the final func } else { b("some data", cb); } }, c, d ], function(err, data) { //do something }); 或者如果他们是承诺… a("some data") […]