Tag: asynchronous

Node.js用于循环asynchronous请求

我有for循环请求（和callback中的另一个请求）。 我有内存使用问题（当我经历了很多请求的同时） 这里是示例代码： var request = require('request'); for(var j=1;j<=10;j++){ request({ method: 'GET', url: 'https://api.domain.com/items/?page='+j+'&limit=1000', headers: { 'Content-Type': 'application/json' }}, function (error, response, body) { var data = JSON.parse(body) for(var i=0;i<data.length;i++){ request({ method: 'GET', url: 'https://api.domain.com/itemDetail/'+data[i].id, headers: { 'Content-Type': 'application/json', }}, function (error, response, body) { var itemDetails = JSON.parse(body); // save items to mongodb } […]

如何用超时和监听器创build未来

我正在试图创造一个有未来的function。 在这个函数中，它将等待一个End或Error事件。 如果没有数据写入x秒，将返回一个错误。 这是我写的。 Cylon.execute = function (subroutine, timeout=60000) { let future = new Future(); let done = future.resolver(); let timeoutId = Meteor.setTimeout(function () { done(new Meteor.Error('CylonTimeout')); }); this._messages.on('data', () => { timeoutId = Meteor.setTimeout(function () { done(new Meteor.Error('CylonTimeout')); }); }); this.on('End', () => { Meteor.clearTimeout(timeoutId); done(null, subroutine); }) this.on('Error', (err) => { Meteor.clearTimeout(timeoutId) done(err, […]

监视阻止调用nodejs

我试图连接到第三方库，它有一个function，可以阻止。 我想用它，但没有阻塞。 是否有可能包装一个我没有控制的阻塞调用，使其asynchronous？ // calling this function will block the nodejs thread blockingCall(); 我想是这样的。 // wrapper for the blocking call var wrapper = wrapBlockingCall(blockingCall); wrapper.on('complete', function() {}); 这可能吗？ 这有道理吗？

在Async瀑布中调用最后的callback有没有什么坏处？

async.waterfall( [ function(cb){ //do some stuff and then never call cb leaving the async waterfall unfinished },…], function(err,result){ //we only get here if the cb is called above and it never is } ) 这有什么伤害吗？ 我意识到它不是按照devise的方法使用的，但是我只是发现了一堆我正在维护的代码（由不再被大声呼喊的人编写），而且我担心这可能会让事情陷入困境。 如果这是在一个服务器上运行的重击，会造成一个问题？

困惑于如何在node.js中实现asynchronouscallback

ytdl(url, { filter: function(format) { return format.container === 'mp4'; } }) .pipe(fs.createWriteStream('./songs/Battle-Scars.mp4')); 我是新的node.js，并试图实现一个youtube-mp3转换器，我不知道如何使上面的代码完成运行后只运行下面的代码。 var proc = new ffmpeg({ source: './songs/Battle-Scars.mp4'}) .withAudioCodec('libmp3lame') .toFormat('mp3') .saveToFile('./songs/Battle-Scars.mp3', function(stdout, stderr) { console.log('file has been converted succesfully'); }); 我感谢所有的帮助和提前感谢。

如何在事件处理程序中进行asynchronous调用？

我试图写一个自定义的摩卡记者，与一个HTTP API的第三方集成。 我接受了自定义记者（ https://github.com/mochajs/mocha/wiki/Third-party-reporters ）的基本示例，并试图在启动事件处理程序中添加对API的调用。 然而，我的HTTP请求callback到第三方似乎从未触发。 示例代码如下所示。 我已经testing了请求代码在其他上下文中按预期工作，它似乎是在摩卡记者的事件处理程序内，没有任何反应。 注意 – 请原谅当前的黑客等待callback的结果，我只是想确保我没有退出之前，callback有机会开火，我会收拾起来，当我得到它的工作！ var request = require('request'); module.exports = function (runner) { var passes = 0; var failures = 0; runner.on('start', function() { var callbackFired = false; request('http://www.testapi.com', function (error, response, body) { callbackFired = true; }); while(!callbackFired){ console.log('waiting…'); } }); runner.on('pass', function(test){ passes++; console.log('pass: %s', test.fullTitle()); […]

等待Node.js表示应用程序调用http.request的for循环

我的头即将爆炸。 请知道，我等了大约一个星期才发布这个。 单凭耻辱，不能把这个混杂在浪费个人时间的巨大数量上，把我置于一个非常黑暗的地方。 我问你interwebs …请告诉我的方式。 我正在编写我的第一个NodeJS Express 4应用程序，它将pipe理我的家庭自动化系统（具有Rest API）。 杀死我的事情是我有99％的代码完成，我只是不能让它等待循环的http.request完成之前，调用我的callback函数出下面的函数。 我试过，DeAsync，Async，wait.for，…我似乎无法得到它主要是因为在一个for循环。 任何人都可以帮我解决这个问题。 我只是无法把我的脑袋绕过asynchronous或callback，以防止这个问题。 最主要的是它需要一个名为value对象的对象，然后循环它们，调用一个web服务，填充一个我调用的对象：ISYGetData，最后应该触发主callback，然后触发另一个函数来呈现一个web页面模板与响应中的数据。 任何帮助将不胜感激。 function runISYGet(runISYGetInput, resInput, runISYGetCallback) { //console.dir(runISYGetInput); //console.log('length:' + runISYGetInput.length); ISYGetData = []; for (var i = 0; i < runISYGetInput.length; i++) { // runISYGetInput Object Example: // runISYGetInput = [ // { id: "36981", operation: "on" } // , { […]

在node.js中的for循环之后完成多个writeFile函数完成时的promise

首先，这是我现在的代码的一部分： return new Promise(function(resolve, reject) { for (var i = 1; i <= variables; i++) { fs.writeFile("file-" + i + ".txt", dataString + ' ' + i + ' 0', "utf-8"); } if (i == variables) resolve('Files have been written'); else reject('Some error occured'); }) 我的问题是，我不知道如何告诉我的承诺，解决所有文件写入writeFile()是asynchronous后。 我想要做的是在我的下一个then()使用这些文件，当他们完全写入我的驱动器。 有人可以帮我吗？ 我现在有点迷路，也是node.js的新手，请耐心等待:) 提前致谢！ #UPDATE 1： var promises = […]

有没有可能限制节点中的asynchronous任务？

我有以下部分的asynchronous代码… async.forEach(list, function(file, loopCallback) { console.log("file"); loopCallback(); }, { console.log("all done!"); }); 这是好的，它打印我的列表中的所有文件的名称。 大。 但是现在，让我们想象一下，我想一次限制文件的数量。 比如，如果我只想让一次只能做一个文件呢？ 我听说过async.ParallelLimit和async.Queue，并且想知道如何调整这个代码来适应其中的一个（特别是parallelLimit）。 有任何想法吗？

如何使节点js的asynchronousfunction在节点js中同步处理

在节点js我有一个aws API调用for循环。 var prodAdvOptions = { host : "webservices.amazon.in", region : "IN", version : "2013-08-01", path : "/onca/xml" }; prodAdv = aws.createProdAdvClient(awsAccessKeyId, awsSecretKey, awsAssociateTag, prodAdvOptions); var n=100//Just for test for (var i = 0; i <=n; i++) { prodAdv.call("ItemSearch", { SearchIndex : "All", Keywords : "health,fitness,baby care,beauty", ResponseGroup : 'Images,ItemAttributes,Offers,Reviews', Availability : 'Available', ItemPage : […]