async.js

0热度

1回答

我遇到了使用async.eachLimit的问题。它适用于前10个元素，但它不会继续过去;它只是结束。所以，如果有100个元素，它只会在前10个元素。这显然是我误解回调的问题。使用eachLimit和不包含回调的外部函数的正确方法是什么？还是这样的功能需要一个？ async.eachLimit(items, 10, function(item, callback) { outsideF

0热度

1回答

遍历数组，并基于该阵列中的每个条目前面的查询结果执行我的SQL查询

我有一个项目数组： var myArr = ['item1', 'item2', 'item3']; 我试图遍历这些项目，并检查它们是否存在于我的数据库中。如果该项目不存在，那么我将它添加到数据库中。 var sql = 'Select * from DB where item="' + myArr[i] + '"'; connection.query(sql, function(e, r,

1热度

1回答

系统 - 睡眠不正常

我想将所有从数据库中取出的数据存储在arr_obj中，然后使用这个变量int async.forEachLimit函数。出于这个原因，我使用async.series函数，除睡眠（1000）以外，一切正常，只要调用了async.series的第二个函数，代码就会休眠，然后将所有结果一起给出。在NodeJs中，我没有初学者对这一切有很多想法。 var sleep = require('system-s

0热度

1回答

节点在调用res.end（）之前res.write所有数据

尝试写入所有文件，然后结束响应，但在完成所有写入之前以某种方式调用res.end。我如何解决它，做所有的写作，并在那之后调用res.end（）？错误味精大气压：错误：结束后写 app.get('/api/upload', function (req, res) { gfs.files.find({}).toArray(function (err, files) { if

0热度

1回答

异步每对HTTP PUT

我尝试发送多个HTTP PUT请求到我的服务器，但我只管理一个JSON发送到数据库，我是缺少在这里 var data1 = JSON.stringify(require('./abc.json')), data2 = JSON.stringify(require('./abe.json')), data3 = JSON.stringify(require('./abd.json

0热度

3回答

nodejs如何让循环等待，直到运行循环的下一个实例

我正在使用mongodb和bigquery的nodejs。因为它似乎bigquery只允许每个命令10k插入。所以我做了主要查询计数，并循环到从10K多少页。我得到500k与计数查询，所以50页或500循环。如何让循环等待直到运行循环的下一页？代码： var limit = 9999; mongo_client.connect(mongo_url, function(err, db)

0热度

1回答

在地图node.js中使用瀑布

async.map(map, function(item, mnext){ async.waterfall([ function(wnext){ console.log("1"); //mongodb queryies something like db.collection.find().toArray(function(err){

-2热度

2回答

Node.js的异步时间过长执行

我有我的查询阵列 var array = [ 'UPDATE EVALUATION SET mark = "16" WHERE id_eval = "21" AND id_usr = "125"', 'UPDATE EVALUATION SET mark = "9" WHERE id_eval = "22" AND id_usr = "125"', 'UPDATE

0热度

1回答

使用waterline orm，mongodb和async.parallel更新数据库记录

我是nodejs开发人员。我正在使用Mongodb和waterline ORM和异步库来执行更新任务。以下是我关注的步骤 function update(task, payload, next) { const self = this; async.auto({ createUpdateObj : (callback) => { let update

1热度

1回答

对数组中的每个对象执行多个异步操作的意外结果

我对Node.js比较陌生，仍然围绕着回调和Node.js的异步本质进行了包装。我遇到了一个我无法解决的问题;我已经彻底搜索了溢出并阅读了支持文档，但仍无法使其工作。本质上，问题是我有一个对象数组，我想对每个对象应用一系列的异步操作。我查看了Async.js并尝试了各种回调结构，但是我的编译器只是不停地向我大喊。我的代码的最新版本是： function processObjects(objec